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) {
* of each other (each one uses a separate thread for delivering
events), allowing slower
* listeners to be somewhat isolated from others.
*/
- private def addToQueue(listener: SparkListenerInterface, queue: String):
Unit = synchronized {
+ private[spark] def addToQueue(
--- End diff --
Change it in order to call it in StreamingQueryListenerBus.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
