Skip to content

Commit

Permalink
[SPARK-32850][TEST][FOLLOWUP] Fix flaky test due to timeout
Browse files Browse the repository at this point in the history
### What changes were proposed in this pull request?

Increase test timeout.

### Why are the changes needed?

It's more reasonable to use 60s instead of 6s since many code place use the 60s in `TestUtils.waitUntilExecutorsUp`.

### Does this PR introduce _any_ user-facing change?

No.

### How was this patch tested?

Pass exists test.

Closes #31166 from ulysses-you/SPARK-32850-FOLLOWUP.

Authored-by: ulysses-you <ulyssesyou18@gmail.com>
Signed-off-by: HyukjinKwon <gurwls223@apache.org>
(cherry picked from commit f64297d)
Signed-off-by: HyukjinKwon <gurwls223@apache.org>
  • Loading branch information
ulysses-you authored and HyukjinKwon committed Jan 13, 2021
1 parent 6f95815 commit 6ee2618
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ class BlockManagerDecommissionIntegrationSuite extends SparkFunSuite with LocalS
.set(config.DECOMMISSION_ENABLED, true)
.set(config.STORAGE_DECOMMISSION_ENABLED, isEnabled)
sc = new SparkContext(conf)
TestUtils.waitUntilExecutorsUp(sc, 2, 6000)
TestUtils.waitUntilExecutorsUp(sc, 2, 60000)
val executors = sc.getExecutorIds().toArray
val decommissionListener = new SparkListener {
override def onTaskStart(taskStart: SparkListenerTaskStart): Unit = {
Expand Down

0 comments on commit 6ee2618

Please sign in to comment.