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 StreamingQueryListenerBus(sparkListenerBus:
LiveListenerBus)
import StreamingQueryListener._
- sparkListenerBus.addToSharedQueue(this)
+ sparkListenerBus.addToQueue(this, "streams")
--- End diff --
nit: wanna make this a constant?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
