use thread name for error message

Author: bowenliang123

externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala

@@ -173,8 +173,7 @@ case class SparkSQLEngine(spark: SparkSession) extends Serverable("SparkSQLEngin
         checkTask,
         interval,
         interval,
-        TimeUnit.MILLISECONDS,
-        "spark-engine-lifetime-terminating-checker")
+        TimeUnit.MILLISECONDS)
     }
   }
 }

externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/session/SparkSQLSessionManager.scala

@@ -85,8 +85,7 @@ class SparkSQLSessionManager private (name: String, spark: SparkSession)
           },
           userIsolatedIdleInterval,
           userIsolatedIdleInterval,
-          TimeUnit.MILLISECONDS,
-          "user-isolated-spark-session-cache-checker")
+          TimeUnit.MILLISECONDS)
       }
     }
   }

kyuubi-common/src/main/scala/org/apache/kyuubi/session/SessionManager.scala

@@ -330,8 +330,7 @@ abstract class SessionManager(name: String) extends CompositeService(name) {
       checkTask,
       interval,
       interval,
-      TimeUnit.MILLISECONDS,
-      "session-timeout-checker")
+      TimeUnit.MILLISECONDS)
   }
 
   private[kyuubi] def startTerminatingChecker(stop: () => Unit): Unit = if (!isServer) {
@@ -354,8 +353,7 @@ abstract class SessionManager(name: String) extends CompositeService(name) {
         checkTask,
         interval,
         interval,
-        TimeUnit.MILLISECONDS,
-        "session-manager-terminating-checker")
+        TimeUnit.MILLISECONDS)
     }
   }
 }

kyuubi-common/src/main/scala/org/apache/kyuubi/util/ThreadUtils.scala

@@ -119,14 +119,14 @@ object ThreadUtils extends Logging {
       runnable: Runnable,
       initialDelay: Long,
       delay: Long,
-      timeUnit: TimeUnit,
-      errorMessageHint: String): Unit = {
+      timeUnit: TimeUnit): Unit = {
     scheduler.scheduleWithFixedDelay(
       () =>
         try {
           runnable.run()
         } catch {
-          case e: Exception => error(s"Error in $errorMessageHint", e)
+          case t: Throwable =>
+            error(s"Uncaught exception in thread ${Thread.currentThread().getName}", t)
         },
       initialDelay,
       delay,

kyuubi-server/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala

@@ -131,8 +131,7 @@ class KyuubiSyncThriftClient private (
       task,
       engineAliveProbeInterval,
       engineAliveProbeInterval,
-      TimeUnit.MILLISECONDS,
-      "engine-alive-probe-checker")
+      TimeUnit.MILLISECONDS)
   }
 
   /**

kyuubi-server/src/main/scala/org/apache/kyuubi/credentials/HadoopCredentialsManager.scala

@@ -305,8 +305,7 @@ class HadoopCredentialsManager private (name: String) extends AbstractService(na
         checkTask,
         credentialsCheckInterval,
         credentialsCheckInterval,
-        TimeUnit.MILLISECONDS,
-        "hadoop-credentials-timeout-checker")
+        TimeUnit.MILLISECONDS)
     }
   }
 

kyuubi-server/src/main/scala/org/apache/kyuubi/server/KyuubiRestFrontendService.scala

@@ -148,8 +148,7 @@ class KyuubiRestFrontendService(override val serverable: Serverable)
       task,
       interval,
       interval,
-      TimeUnit.MILLISECONDS,
-      "batch-checker")
+      TimeUnit.MILLISECONDS)
   }
 
   @VisibleForTesting

kyuubi-server/src/main/scala/org/apache/kyuubi/server/PeriodicGCService.scala

@@ -46,7 +46,6 @@ class PeriodicGCService(name: String) extends AbstractService(name) {
       () => System.gc(),
       interval,
       interval,
-      TimeUnit.MILLISECONDS,
-      "periodic-gc-trigger")
+      TimeUnit.MILLISECONDS)
   }
 }

kyuubi-server/src/main/scala/org/apache/kyuubi/server/metadata/MetadataManager.scala

@@ -215,8 +215,7 @@ class MetadataManager extends AbstractService("MetadataManager") {
       cleanerTask,
       interval,
       interval,
-      TimeUnit.MILLISECONDS,
-      "metadata-cleaner")
+      TimeUnit.MILLISECONDS)
   }
 
   def addMetadataRetryRequest(request: MetadataRequest): Unit = {
@@ -307,8 +306,7 @@ class MetadataManager extends AbstractService("MetadataManager") {
       triggerTask,
       requestsRetryInterval,
       requestsRetryInterval,
-      TimeUnit.MILLISECONDS,
-      "metadata-request-async-retry-trigger")
+      TimeUnit.MILLISECONDS)
   }
 }
 

kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionManager.scala

@@ -415,8 +415,7 @@ class KyuubiSessionManager private (name: String) extends SessionManager(name) {
       checkTask,
       interval,
       interval,
-      TimeUnit.MILLISECONDS,
-      "engine-connection-alive-checker")
+      TimeUnit.MILLISECONDS)
   }
 
   private def initEngineStartupProcessSemaphore(conf: KyuubiConf): Unit = {