Update SparkKubernetesApp.scala

apache · Feb 4, 2025 · bdc9877 · bdc9877
1 parent 7b88c8f
commit bdc9877
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/server/src/main/scala/org/apache/livy/utils/SparkKubernetesApp.scala b/server/src/main/scala/org/apache/livy/utils/SparkKubernetesApp.scala
@@ -33,6 +33,7 @@ import org.apache.commons.lang3.StringUtils
 import org.apache.livy.{LivyConf, Logging}
 
 import java.util
+import scala.collection.JavaConverters.asScalaSetConverter
 import scala.collection.mutable
 
 object SparkKubernetesApp extends Logging {
@@ -138,7 +139,7 @@ object SparkKubernetesApp extends Logging {
   private var sessionLeakageCheckInterval: Long = _
 
   var kubernetesClient: DefaultKubernetesClient = _
-  var appNamespaces: mutable.Set[String] = mutable.Set("default")
+  var appNamespaces: mutable.Set[String] = java.util.concurrent.ConcurrentHashMap.newKeySet[String]().asScala
 
   private var appLookupThreadPoolSize: Long = _
   private var appLookupMaxFailedTimes: Long = _