diff options
| author | Brennon York <brennon.york@capitalone.com> | 2015-01-04 12:40:39 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@databricks.com> | 2015-01-04 12:40:39 -0800 |
| commit | b96008d5529bac5fd57b76554fd01760139cffff (patch) | |
| tree | 48762a0d15fe716de159786e918701a5b9009455 | |
| parent | 342612b65f3d77c660383a332f0346872f076647 (diff) | |
| download | spark-b96008d5529bac5fd57b76554fd01760139cffff.tar.gz spark-b96008d5529bac5fd57b76554fd01760139cffff.tar.bz2 spark-b96008d5529bac5fd57b76554fd01760139cffff.zip | |
[SPARK-794][Core] Remove sleep() in ClusterScheduler.stop
Removed `sleep()` from the `stop()` method of the `TaskSchedulerImpl` class which, from the JIRA ticket, is believed to be a legacy artifact slowing down testing originally introduced in the `ClusterScheduler` class.
Author: Brennon York <brennon.york@capitalone.com>
Closes #3851 from brennonyork/SPARK-794 and squashes the following commits:
04c3e64 [Brennon York] Removed sleep() from the stop() method
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala index cd3c015321..a41f3eef19 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala @@ -394,9 +394,6 @@ private[spark] class TaskSchedulerImpl( taskResultGetter.stop() } starvationTimer.cancel() - - // sleeping for an arbitrary 1 seconds to ensure that messages are sent out. - Thread.sleep(1000L) } override def defaultParallelism() = backend.defaultParallelism() |