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 ac4ef6e9e4623..affc2018c43cb 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 @@ -834,8 +834,8 @@ class StreamExecution( private def getBatchDescriptionString: String = { val batchDescription = if (currentBatchId < 0) "init" else currentBatchId.toString - Option(name).map(_ + " ").getOrElse("") + - s"[batch = $batchDescription,
id = $id,
runId = $runId]" + Option(name).map(_ + "
").getOrElse("") + + s"id = $id
runId = $runId
batch = $batchDescription" } }