Merge pull request #155 from rxin/jobgroup

Don't reset job group when a new job description is set.
2013-11-09 15:40:29 -08:00 · 2013-11-09 15:40:29 -08:00 · 83bf1920c8
parent 8af99f2356 28f27097cf
commit 83bf1920c8
1 changed files with 1 additions and 1 deletions
--- a/core/src/main/scala/org/apache/spark/SparkContext.scala
+++ b/core/src/main/scala/org/apache/spark/SparkContext.scala
@ -307,7 +307,7 @@ class SparkContext(
  /** Set a human readable description of the current job. */
  @deprecated("use setJobGroup", "0.8.1")
  def setJobDescription(value: String) {
-    setJobGroup("", value)
+    setLocalProperty(SparkContext.SPARK_JOB_DESCRIPTION, value)
  }

  /**