diff options
| author | Reynold Xin <rxin@apache.org> | 2013-11-09 13:59:31 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2013-11-09 13:59:31 -0800 |
| commit | 28f27097cf5a88d34f55a44597ea416742848a8f (patch) | |
| tree | a1265cb3868d5b045e562c94d3b0989e2755b797 | |
| parent | 319299941dbf4bfa2aaa8b5078e313ca45cb5207 (diff) | |
| download | spark-28f27097cf5a88d34f55a44597ea416742848a8f.tar.gz spark-28f27097cf5a88d34f55a44597ea416742848a8f.tar.bz2 spark-28f27097cf5a88d34f55a44597ea416742848a8f.zip | |
Don't reset job group when a new job description is set.
| -rw-r--r-- | core/src/main/scala/org/apache/spark/SparkContext.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index dbb354d3b7..d884095671 100644 --- 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) } /** |