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 /core/src | |
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
Diffstat (limited to 'core/src')
-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() |