Modified comment in SchedulerBackend#applicationId and TaskScheduler#…

…applicationId
avulanov · Sep 25, 2014 · 203634e · 203634e
1 parent 424fea4
commit 203634e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/SchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/SchedulerBackend.scala
@@ -34,9 +34,11 @@ private[spark] trait SchedulerBackend {
 
   /**
    * The application ID associated with the job, if any.
+   * It is expected that the subclasses of TaskScheduler or SchedulerBackend
+   * override this method and return an unique application ID.
    *
-   * @return The application ID, or None if the backend does not provide an ID.
+   * @return The application ID, if the backend does not provide an ID.
    */
-  def applicationId(): Option[String] = None
+  def applicationId(): String = System.currentTimeMillis.toString
 
 }
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala
@@ -67,8 +67,10 @@ private[spark] trait TaskScheduler {
 
   /**
    * The application ID associated with the job, if any.
+   * It is expected that the subclasses of TaskScheduler or SchedulerBackend
+   * override this method and return an unique application ID.
    *
-   * @return The application ID, or None if the backend does not provide an ID.
+   * @return The application ID, if the backend does not provide an ID.
    */
   def applicationId(): String = System.currentTimeMillis.toString