diff options
| author | Kay Ousterhout <kayousterhout@gmail.com> | 2013-11-13 15:46:41 -0800 |
|---|---|---|
| committer | Kay Ousterhout <kayousterhout@gmail.com> | 2013-11-13 17:12:14 -0800 |
| commit | 46f9c6b858cf9737b7d46b22b75bfc847244331b (patch) | |
| tree | 0cf52d1772e0ee97732ebe2f70267837b28b1f70 /yarn | |
| parent | 150615a31e0c2a5112c37cca62dd80dba8a12fab (diff) | |
| download | spark-46f9c6b858cf9737b7d46b22b75bfc847244331b.tar.gz spark-46f9c6b858cf9737b7d46b22b75bfc847244331b.tar.bz2 spark-46f9c6b858cf9737b7d46b22b75bfc847244331b.zip | |
Fixed naming issues and added back ability to specify max task failures.
Diffstat (limited to 'yarn')
| -rw-r--r-- | yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClusterScheduler.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClusterScheduler.scala b/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClusterScheduler.scala index e873400680..4e988b8017 100644 --- a/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClusterScheduler.scala +++ b/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClusterScheduler.scala @@ -21,16 +21,16 @@ import org.apache.hadoop.conf.Configuration import org.apache.spark._ import org.apache.spark.deploy.yarn.{ApplicationMaster, YarnAllocationHandler} -import org.apache.spark.scheduler.TaskScheduler +import org.apache.spark.scheduler.ClusterScheduler import org.apache.spark.util.Utils /** * - * This is a simple extension to TaskScheduler - to ensure that appropriate initialization of + * This is a simple extension to ClusterScheduler - to ensure that appropriate initialization of * ApplicationMaster, etc. is done */ private[spark] class YarnClusterScheduler(sc: SparkContext, conf: Configuration) - extends TaskScheduler(sc) { + extends ClusterScheduler(sc) { logInfo("Created YarnClusterScheduler") |