Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21356#discussion_r189100750
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala ---
@@ -97,6 +98,11 @@ private class AsyncEventQueue(val name: String, conf:
SparkConf, metrics: LiveLi
} catch {
case ie: InterruptedException =>
logInfo(s"Stopping listener queue $name.", ie)
+ stopped.set(true)
--- End diff --
I wonder if this is the right thing to do. What would the old bus do here?
I remember there's code to catch exceptions from listeners and just log
them, so that other listeners in the same queue are not affected. Not that the
event writer queue would suffer from that, but others might.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
