add lock

Author: JingsongLi

paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/PaimonHiveTestBase.scala

@@ -18,15 +18,16 @@
 
 package org.apache.paimon.spark
 
+import javolution.util.ReentrantLock
 import org.apache.paimon.hive.TestHiveMetastore
 import org.apache.paimon.table.FileStoreTable
-
 import org.apache.hadoop.conf.Configuration
 import org.apache.spark.SparkConf
 import org.apache.spark.sql.paimon.Utils
 
 import java.io.File
 import java.util.concurrent.ThreadLocalRandom
+import java.util.concurrent.locks.Lock
 
 class PaimonHiveTestBase extends PaimonSparkTestBase {
 
@@ -60,6 +61,7 @@ class PaimonHiveTestBase extends PaimonSparkTestBase {
   }
 
   override protected def beforeAll(): Unit = {
+    lock.lock()
     testHiveMetastore.start(hivePort)
     super.beforeAll()
     spark.sql(s"USE $sparkCatalogName")
@@ -71,6 +73,7 @@ class PaimonHiveTestBase extends PaimonSparkTestBase {
       spark.sql(s"USE $sparkCatalogName")
       spark.sql("USE default")
       spark.sql(s"DROP DATABASE $hiveDbName CASCADE")
+      lock.unlock()
     } finally {
       super.afterAll()
       testHiveMetastore.stop()
@@ -97,4 +100,6 @@ object PaimonHiveTestBase {
   }
 
   val hivePort: Int = hiveUri.split(":")(2).toInt
+
+  val lock = new ReentrantLock
 }