Skip to content

Commit 6a69126

Browse files
committed
On github actions the listener might take more time to finish, and add a comment
1 parent cc76ff5 commit 6a69126

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -242,8 +242,10 @@ class DecommissionWorkerSuite
242242
assert(jobResult === 2)
243243
}
244244
// 6 tasks: 2 from first stage, 2 rerun again from first stage, 2nd stage attempt 1 and 2.
245-
val tasksSeen = listener.getTasksFinished()
246-
assert(tasksSeen.size === 6, s"Expected 6 tasks but got $tasksSeen")
245+
eventually(timeout(30.seconds), interval(10.seconds)) {
246+
val tasksSeen = listener.getTasksFinished()
247+
assert(tasksSeen.size === 6, s"Expected 6 tasks but got $tasksSeen")
248+
}
247249
}
248250

249251
private abstract class RootStageAwareListener extends SparkListener {

core/src/test/scala/org/apache/spark/storage/BlockManagerDecommissionIntegrationSuite.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -188,6 +188,8 @@ class BlockManagerDecommissionIntegrationSuite extends SparkFunSuite with LocalS
188188

189189
val execToDecommission = getCandidateExecutorToDecom.get
190190
logInfo(s"Decommissioning executor ${execToDecommission}")
191+
192+
// Decommission executor and ensure it is not relaunched by setting adjustTargetNumExecutors
191193
sched.decommissionExecutor(
192194
execToDecommission,
193195
ExecutorDecommissionInfo("", isHostDecommissioned = false),

0 commit comments

Comments
 (0)