Github user brkyvz commented on a diff in the pull request:
https://github.com/apache/spark/pull/19838#discussion_r153910748
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingQueryListenerBus.scala
---
@@ -40,7 +40,7 @@ class StreamingQueryListene
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/19838#discussion_r153908979
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala ---
@@ -87,7 +87,9 @@ private[spark] class LiveListenerBus(conf: SparkConf) {
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/19838#discussion_r153674694
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala ---
@@ -87,7 +87,9 @@ private[spark] class LiveListenerBus(conf: SparkCon
GitHub user zsxwing opened a pull request:
https://github.com/apache/spark/pull/19838
[SPARK-22638][SS]Use a separate query for StreamingQueryListenerBus
## What changes were proposed in this pull request?
Use a separate Spark event query for StreamingQueryListenerBus so tha
