review

apache · Dec 31, 2024 · 343adae · 343adae
1 parent 3eade8b
commit 343adae
Showing 1 changed file with 2 additions and 5 deletions.
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
@@ -337,11 +337,8 @@ class SparkProcessBuilder(
   }
 
   def isK8sClusterMode: Boolean = {
-    clusterManager().map(_.toLowerCase(Locale.ROOT)) match {
-      case Some(m) if m.startsWith("k8s") =>
-        deployMode().exists(_.toLowerCase(Locale.ROOT) == "cluster")
-      case _ => false
-    }
+    clusterManager().exists(cm => cm.toLowerCase(Locale.ROOT).startsWith("k8s")) &&
+      deployMode().exists(_.toLowerCase(Locale.ROOT) == "cluster")
   }
 
   def kubernetesContext(): Option[String] = {