-
- Downloads
[SPARK-7989] [CORE] [TESTS] Fix flaky tests in ExternalShuffleServiceSuite and...
[SPARK-7989] [CORE] [TESTS] Fix flaky tests in ExternalShuffleServiceSuite and SparkListenerWithClusterSuite The flaky tests in ExternalShuffleServiceSuite and SparkListenerWithClusterSuite will fail if there are not enough executors up before running the jobs. This PR adds `JobProgressListener.waitUntilExecutorsUp`. The tests for the cluster mode can use it to wait until the expected executors are up. Author: zsxwing <zsxwing@gmail.com> Closes #6546 from zsxwing/SPARK-7989 and squashes the following commits: 5560e09 [zsxwing] Fix a typo 3b69840 [zsxwing] Fix flaky tests in ExternalShuffleServiceSuite and SparkListenerWithClusterSuite
Showing
- core/src/main/scala/org/apache/spark/ui/jobs/JobProgressListener.scala 30 additions, 0 deletions.../scala/org/apache/spark/ui/jobs/JobProgressListener.scala
- core/src/test/scala/org/apache/spark/ExternalShuffleServiceSuite.scala 8 additions, 0 deletions.../scala/org/apache/spark/ExternalShuffleServiceSuite.scala
- core/src/test/scala/org/apache/spark/broadcast/BroadcastSuite.scala 1 addition, 9 deletions...est/scala/org/apache/spark/broadcast/BroadcastSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/SparkListenerWithClusterSuite.scala 7 additions, 3 deletions...pache/spark/scheduler/SparkListenerWithClusterSuite.scala
Loading
Please register or sign in to comment