Added warning message for the situation we cannot get application id …

…for the prefix for the name of metrics
avulanov · Sep 22, 2014 · 36d2f7a · 36d2f7a
1 parent eea6e19
commit 36d2f7a
Showing 1 changed file with 5 additions 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
@@ -310,7 +310,11 @@ class SparkContext(config: SparkConf) extends Logging {
   // constructor
   taskScheduler.start()
 
-  val appId = taskScheduler.applicationId().getOrElse(System.currentTimeMillis().toString)
+  val appId = taskScheduler.applicationId().getOrElse({
+    logWarning("Failed to get unique Application ID. " +
+      "Instead of Application ID, UNIX time is used for the prefix of the name of metrics.")
+    System.currentTimeMillis().toString
+  })
   conf.set("spark.app.id", appId)
 
   val metricsSystem = env.metricsSystem