diff options
| author | Kay Ousterhout <kayousterhout@gmail.com> | 2013-10-31 23:42:56 -0700 |
|---|---|---|
| committer | Kay Ousterhout <kayousterhout@gmail.com> | 2013-10-31 23:42:56 -0700 |
| commit | fb64828b0b573f3a77938592f168af7aa3a2b6c5 (patch) | |
| tree | 45328b142c5a7d67b1a461821c71df62f103e8d3 /core/src/main/scala/org/apache | |
| parent | a124658e53a5abeda00a2582385a294c8e452d21 (diff) | |
| download | spark-fb64828b0b573f3a77938592f168af7aa3a2b6c5.tar.gz spark-fb64828b0b573f3a77938592f168af7aa3a2b6c5.tar.bz2 spark-fb64828b0b573f3a77938592f168af7aa3a2b6c5.zip | |
Cleaned up imports and fixed test bug
Diffstat (limited to 'core/src/main/scala/org/apache')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala | 3 | ||||
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala | 1 |
2 files changed, 1 insertions, 3 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala index 3f694dd25d..b4ec695ece 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala @@ -27,7 +27,6 @@ import scala.collection.mutable.HashSet import org.apache.spark._ import org.apache.spark.TaskState.TaskState -import org.apache.spark.scheduler._ import org.apache.spark.scheduler.SchedulingMode.SchedulingMode /** @@ -449,7 +448,7 @@ private[spark] class TaskScheduler(val sc: SparkContext, isLocal: Boolean = fals } -object TaskScheduler { +private[spark] object TaskScheduler { /** * Used to balance containers across hosts. * diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala index 13271b10f3..90b6519027 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala @@ -28,7 +28,6 @@ import scala.math.min import org.apache.spark.{ExceptionFailure, FetchFailed, Logging, Resubmitted, SparkEnv, Success, TaskEndReason, TaskKilled, TaskResultLost, TaskState} import org.apache.spark.TaskState.TaskState -import org.apache.spark.scheduler._ import org.apache.spark.util.{SystemClock, Clock} |