Remove extra setJobDesc.

kunalkhamar · kunalkhamar · commit 992d68fca1b1 · 2017-04-27T15:28:37.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
@@ -482,7 +482,6 @@ class StreamExecution(
       case None => // We are starting this stream for the first time.
         logInfo(s"Starting new streaming query.")
         currentBatchId = 0
-        sparkSession.sparkContext.setJobDescription(getBatchDescriptionString)
         constructNextBatch()
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -482,7 +482,6 @@ class StreamExecution(`
`482`	`482`	`case None => // We are starting this stream for the first time.`
`483`	`483`	`logInfo(s"Starting new streaming query.")`
`484`	`484`	`currentBatchId = 0`
`485`		`- sparkSession.sparkContext.setJobDescription(getBatchDescriptionString)`
`486`	`485`	`constructNextBatch()`
`487`	`486`	`}`
`488`	`487`	`}`