Update BatchSession.scala

Ashok Kumar · Ashok Kumar · commit c96086c1ccfb · 2025-03-13T13:47:50.000+05:30
diff --git a/server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala b/server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala
@@ -140,7 +140,7 @@ object BatchSession extends Logging {
       sessionStore,
       m.namespace,
       mockApp.map { m => (_: BatchSession) => m }.getOrElse { s =>
-        SparkApp.create(m.appTag, m.appId, None, livyConf, Option(s), Map[String, String]())
+        SparkApp.create(m.appTag, m.appId, None, livyConf, Option(s), Map(SparkApp.SPARK_KUBERNETES_NAMESPACE_KEY -> m.namespace))
       })
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -140,7 +140,7 @@ object BatchSession extends Logging {`
`140`	`140`	`sessionStore,`
`141`	`141`	`m.namespace,`
`142`	`142`	`mockApp.map { m => (_: BatchSession) => m }.getOrElse { s =>`
`143`		`- SparkApp.create(m.appTag, m.appId, None, livyConf, Option(s), Map[String, String]())`
	`143`	`+ SparkApp.create(m.appTag, m.appId, None, livyConf, Option(s), Map(SparkApp.SPARK_KUBERNETES_NAMESPACE_KEY -> m.namespace))`
`144`	`144`	`})`
`145`	`145`	`}`
`146`	`146`	`}`