holdenk commented on a change in pull request #29211:
URL: https://github.com/apache/spark/pull/29211#discussion_r464759198
##########
File path:
core/src/test/scala/org/apache/spark/scheduler/WorkerDecommissionSuite.scala
##########
@@ -76,13 +79,5 @@ class WorkerDecommissionSuite extends SparkFunSuite with
LocalSparkContext {
execs.foreach(execId => sched.decommissionExecutor(execId,
ExecutorDecommissionInfo("", false)))
val asyncCountResult = ThreadUtils.awaitResult(asyncCount, 20.seconds)
assert(asyncCountResult === 10)
- // Try and launch task after decommissioning, this should fail
- val postDecommissioned = input.map(x => x)
- val postDecomAsyncCount = postDecommissioned.countAsync()
- val thrown = intercept[java.util.concurrent.TimeoutException]{
- val result = ThreadUtils.awaitResult(postDecomAsyncCount, 20.seconds)
- }
- assert(postDecomAsyncCount.isCompleted === false,
- "After exec decommission new task could not launch")
Review comment:
This is removed because we relaunch it now so it would succeed.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
