Update batch desc format.

apache · Apr 28, 2017 · 6e66638 · 6e66638
1 parent f9342c9
commit 6e66638
Showing 1 changed file with 2 additions and 2 deletions.
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
@@ -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,<br/>id = $id,<br/>runId = $runId]"
+    Option(name).map(_ + "<br/>").getOrElse("") +
+      s"id = $id<br/>runId = $runId<br/>batch = $batchDescription"
   }
 }