fix

apache · Oct 20, 2022 · 0d40508 · 0d40508
1 parent a1fcf7f
commit 0d40508
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/spark/SparkProcessBuilder.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/spark/SparkProcessBuilder.scala
@@ -176,7 +176,7 @@ class SparkProcessBuilder(
   // For spark on kubernetes, spark pod using env SPARK_USER_NAME as current user
   def setSparkUserName(userName: String, buffer: ArrayBuffer[String]): Unit = {
     clusterManager().foreach(cm => {
-      if (cm.startsWith("k8s://")) {
+      if (cm.toUpperCase.startsWith("K8S")) {
         buffer += CONF
         buffer += s"spark.kubernetes.driverEnv.SPARK_USER_NAME=$userName"
         buffer += CONF