diff options
author | liguoqiang <liguoqiang@rd.tuan800.com> | 2013-12-26 11:10:35 +0800 |
---|---|---|
committer | liguoqiang <liguoqiang@rd.tuan800.com> | 2013-12-26 11:10:35 +0800 |
commit | 2bd76f693d87330e8cda9c0a9568ee3addd8a422 (patch) | |
tree | ce3092f5b70daecbd6dd09ae1c50d47403bbb2cc | |
parent | 14fcef72db765d0313d4ce3c986c08069a1a01ae (diff) | |
download | spark-2bd76f693d87330e8cda9c0a9568ee3addd8a422.tar.gz spark-2bd76f693d87330e8cda9c0a9568ee3addd8a422.tar.bz2 spark-2bd76f693d87330e8cda9c0a9568ee3addd8a422.zip |
Renamed ClusterScheduler to TaskSchedulerImpl for yarn and new-yarn
-rw-r--r-- | new-yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala | 3 | ||||
-rw-r--r-- | yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala | 3 |
2 files changed, 2 insertions, 4 deletions
diff --git a/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala b/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala index 96a24cd2b1..784a3112de 100644 --- a/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala +++ b/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala @@ -27,8 +27,7 @@ import scala.collection.JavaConversions._ import scala.collection.mutable.{ArrayBuffer, HashMap, HashSet} import org.apache.spark.Logging -import org.apache.spark.scheduler.SplitInfo -import org.apache.spark.scheduler.TaskSchedulerImpl +import org.apache.spark.scheduler.{SplitInfo,TaskSchedulerImpl} import org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend import org.apache.spark.util.Utils diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala index eeee78f8ad..a01657c9fa 100644 --- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala +++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala @@ -27,8 +27,7 @@ import scala.collection.JavaConversions._ import scala.collection.mutable.{ArrayBuffer, HashMap, HashSet} import org.apache.spark.Logging -import org.apache.spark.scheduler.SplitInfo -import org.apache.spark.scheduler.TaskSchedulerImpl +import org.apache.spark.scheduler.{SplitInfo,TaskSchedulerImpl} import org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend import org.apache.spark.util.Utils |