fix

Author: JingsongLi

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

@@ -26,8 +26,7 @@ import org.apache.spark.SparkConf
 import org.apache.spark.sql.paimon.Utils
 
 import java.io.File
-import java.util.concurrent.{ThreadLocalRandom, TimeUnit}
-import java.util.concurrent.locks.ReentrantLock
+import java.util.concurrent.ThreadLocalRandom
 
 class PaimonHiveTestBase extends PaimonSparkTestBase {
 
@@ -61,22 +60,22 @@ class PaimonHiveTestBase extends PaimonSparkTestBase {
   }
 
   override protected def beforeAll(): Unit = {
-    lock.tryLock(10, TimeUnit.MINUTES)
     testHiveMetastore.start(hivePort)
     super.beforeAll()
     spark.sql(s"USE $sparkCatalogName")
     spark.sql(s"CREATE DATABASE IF NOT EXISTS $hiveDbName")
+    println(s"CREATE DATABASE IF NOT EXISTS $hiveDbName")
   }
 
   override protected def afterAll(): Unit = {
     try {
       spark.sql(s"USE $sparkCatalogName")
       spark.sql("USE default")
       spark.sql(s"DROP DATABASE $hiveDbName CASCADE")
+      println(s"DROP DATABASE $hiveDbName CASCADE")
     } finally {
       super.afterAll()
       testHiveMetastore.stop()
-      lock.unlock()
     }
   }
 
@@ -100,6 +99,4 @@ object PaimonHiveTestBase {
   }
 
   val hivePort: Int = hiveUri.split(":")(2).toInt
-
-  val lock = new ReentrantLock
 }

paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/PaimonFunctionTest.scala

@@ -104,7 +104,7 @@ class PaimonFunctionTest extends PaimonHiveTestBase {
     sql("CREATE FUNCTION myIntSum AS 'org.apache.paimon.spark.sql.MyIntSum'")
     checkAnswer(
       sql(s"SHOW FUNCTIONS FROM $hiveDbName LIKE 'myIntSum'"),
-      Row("spark_catalog.test_hive.myintsum"))
+      Row(s"spark_catalog.$hiveDbName.myintsum"))
 
     withTable("t") {
       sql("CREATE TABLE t (id INT) USING paimon")