diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/KyuubiSparkUtil.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/KyuubiSparkUtil.scala index 053985821..51752d021 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/KyuubiSparkUtil.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/KyuubiSparkUtil.scala @@ -31,8 +31,7 @@ object KyuubiSparkUtil { def globalSparkContext: SparkContext = SparkSession.active.sparkContext - def engineId: String = - globalSparkContext.applicationAttemptId.getOrElse(globalSparkContext.applicationId) + def engineId: String = globalSparkContext.applicationId lazy val diagnostics: String = { val sc = globalSparkContext