-
- Downloads
[SPARK-8001] [CORE] Make AsynchronousListenerBus.waitUntilEmpty throw TimeoutException if timeout
Some places forget to call `assert` to check the return value of `AsynchronousListenerBus.waitUntilEmpty`. Instead of adding `assert` in these places, I think it's better to make `AsynchronousListenerBus.waitUntilEmpty` throw `TimeoutException`. Author: zsxwing <zsxwing@gmail.com> Closes #6550 from zsxwing/SPARK-8001 and squashes the following commits: 607674a [zsxwing] Make AsynchronousListenerBus.waitUntilEmpty throw TimeoutException if timeout
Showing
- core/src/main/scala/org/apache/spark/util/AsynchronousListenerBus.scala 6 additions, 5 deletions...scala/org/apache/spark/util/AsynchronousListenerBus.scala
- core/src/test/scala/org/apache/spark/deploy/LogUrlsStandaloneSuite.scala 2 additions, 2 deletions...cala/org/apache/spark/deploy/LogUrlsStandaloneSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala 9 additions, 9 deletions.../scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala 11 additions, 11 deletions...scala/org/apache/spark/scheduler/SparkListenerSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/SparkListenerWithClusterSuite.scala 1 addition, 1 deletion...pache/spark/scheduler/SparkListenerWithClusterSuite.scala
- yarn/src/test/scala/org/apache/spark/deploy/yarn/YarnClusterSuite.scala 1 addition, 1 deletion...scala/org/apache/spark/deploy/yarn/YarnClusterSuite.scala
Loading
Please register or sign in to comment