File tree Expand file tree Collapse file tree 1 file changed +0
-2
lines changed
core/src/test/scala/org/apache/spark/scheduler Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -60,11 +60,9 @@ class WorkerDecommissionSuite extends SparkFunSuite with LocalSparkContext {
6060 // The master passing message is tested with
6161 val sched = sc.schedulerBackend.asInstanceOf [StandaloneSchedulerBackend ]
6262 val execs = sched.getExecutorIds()
63- println(" execs are " + execs)
6463 execs.foreach(execId => sched.decommissionExecutor(execId))
6564 assert(asyncCount.get() === 10 )
6665 // Try and launch task after decommissioning, this should fail
67- println(" post decom execs are " + sched.getExecutorIds())
6866 val postDecommissioned = input.map(x => x)
6967 val postDecomAsyncCount = postDecommissioned.countAsync()
7068 val thrown = intercept[java.util.concurrent.TimeoutException ]{
You can’t perform that action at this time.
0 commit comments