This is an automated email from the ASF dual-hosted git repository.

xxyu pushed a commit to branch kylin5_beta
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit 3e0c4a8c5cf3ff66ddfcc3965d57bdbd26c65676
Author: Liang.Hua <36814772+jacob...@users.noreply.github.com>
AuthorDate: Fri Apr 28 10:55:20 2023 +0800

    KYLIN-5648 add log for sparder init user (#30347)
    
    Co-authored-by: liang.hua <liang....@kyligence.io>
---
 .../sparder/src/main/scala/org/apache/spark/sql/SparderEnv.scala         | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/SparderEnv.scala
 
b/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/SparderEnv.scala
index 3310f79a97..c31e151202 100644
--- 
a/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/SparderEnv.scala
+++ 
b/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/SparderEnv.scala
@@ -218,6 +218,7 @@ object SparderEnv extends Logging {
       SparkSession.clearActiveSession
       val hostInfoFetcher = new DefaultHostInfoFetcher
       val appName = "sparder-" + 
UserGroupInformation.getCurrentUser.getShortUserName + "-" + 
hostInfoFetcher.getHostname
+      logInfo(s"sparder init 
user:${UserGroupInformation.getCurrentUser.getUserName}")
 
       val isLocalMode = KylinConfig.getInstanceFromEnv.isJobNodeOnly ||
         "true".equals(System.getenv("SPARK_LOCAL")) ||

Reply via email to