Github user lirui-apache commented on a diff in the pull request:
https://github.com/apache/spark/pull/21486#discussion_r193044306
--- Diff: core/src/test/scala/org/apache/spark/HeartbeatReceiverSuite.scala
---
@@ -207,6 +210,54 @@ class HeartbeatReceiverSuite
assert(fakeClusterManager.getExecutorIdsToKill === Set(executorId1,
executorId2))
}
+ test("expired executor should not be offered again (SPARK-24387)") {
+ scheduler = spy(new TaskSchedulerImpl(sc))
--- End diff --
Because I need a functioning scheduler rather than just a mock. And need to
stub the executorHeartbeatReceived method. So I use a spy here.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
