From 992d68fca1b10abff7e8539925a8af237155cc8e Mon Sep 17 00:00:00 2001 From: Kunal Khamar Date: Thu, 27 Apr 2017 15:28:37 -0700 Subject: [PATCH] Remove extra setJobDesc. --- .../apache/spark/sql/execution/streaming/StreamExecution.scala | 1 - 1 file changed, 1 deletion(-) 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 index 556ce583fd282..089a6679382fc 100644 --- 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() } }