Skip to content

Commit 5419cdd

Browse files
author
Devaraj K
committed
Updated KubernetesClusterSchedulerBackendSuite to use 'send' from 'ask'
for sending RemoveExecutor message
1 parent 3f6c1b2 commit 5419cdd

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -282,7 +282,7 @@ class KubernetesClusterSchedulerBackendSuite extends SparkFunSuite with BeforeAn
282282
// No more deletion attempts of the executors.
283283
// This is graceful termination and should not be detected as a failure.
284284
verify(podOperations, times(1)).delete(resolvedPod)
285-
verify(driverEndpointRef, times(1)).ask[Boolean](
285+
verify(driverEndpointRef, times(1)).send(
286286
RemoveExecutor("1", ExecutorExited(
287287
0,
288288
exitCausedByApp = false,
@@ -318,7 +318,7 @@ class KubernetesClusterSchedulerBackendSuite extends SparkFunSuite with BeforeAn
318318
requestExecutorRunnable.getValue.run()
319319
allocatorRunnable.getAllValues.asScala.last.run()
320320
verify(podOperations, never()).delete(firstResolvedPod)
321-
verify(driverEndpointRef).ask[Boolean](
321+
verify(driverEndpointRef).send(
322322
RemoveExecutor("1", ExecutorExited(
323323
1,
324324
exitCausedByApp = true,
@@ -356,7 +356,7 @@ class KubernetesClusterSchedulerBackendSuite extends SparkFunSuite with BeforeAn
356356
val recreatedResolvedPod = expectPodCreationWithId(2, SECOND_EXECUTOR_POD)
357357
allocatorRunnable.getValue.run()
358358
verify(podOperations).delete(firstResolvedPod)
359-
verify(driverEndpointRef).ask[Boolean](
359+
verify(driverEndpointRef).send(
360360
RemoveExecutor("1", SlaveLost("Executor lost for unknown reasons.")))
361361
}
362362

0 commit comments

Comments
 (0)