Replaced taskScheduler.applicationId() with getApplicationId in Spark…

…Context#postApplicationStart
avulanov · Oct 2, 2014 · 389090d · 389090d
1 parent ff45c89
commit 389090d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala
@@ -1303,7 +1303,7 @@ class SparkContext(config: SparkConf) extends Logging {
   private def postApplicationStart() {
     // Note: this code assumes that the task scheduler has been initialized and has contacted
     // the cluster manager to get an application ID (in case the cluster manager provides one).
-    listenerBus.post(SparkListenerApplicationStart(appName, Some(taskScheduler.applicationId()),
+    listenerBus.post(SparkListenerApplicationStart(appName, Some(getApplicationId()),
       startTime, sparkUser))
   }