Skip to content

Commit 778acb4

Browse files
committed
add unit testing to test applicationId in case spark.app.id is set
1 parent af73427 commit 778acb4

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

resource-managers/kubernetes/core/src/test/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesClusterSchedulerBackendSuite.scala

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ class KubernetesClusterSchedulerBackendSuite extends SparkFunSuite with BeforeAn
3636

3737
private val requestExecutorsService = new DeterministicScheduler()
3838
private val sparkConf = new SparkConf(false)
39-
.set("spark.executor.instances", "3")
39+
.set("spark.executor.instances", "3").set("spark.app.id", TEST_SPARK_APP_ID)
4040

4141
@Mock
4242
private var sc: SparkContext = _
@@ -100,9 +100,7 @@ class KubernetesClusterSchedulerBackendSuite extends SparkFunSuite with BeforeAn
100100
podAllocator,
101101
lifecycleEventHandler,
102102
watchEvents,
103-
pollEvents) {
104-
override def applicationId(): String = TEST_SPARK_APP_ID
105-
}
103+
pollEvents)
106104
}
107105

108106
test("Start all components") {

0 commit comments

Comments
 (0)