Github user squito commented on the issue:
https://github.com/apache/spark/pull/21356
> does this mean a problematic listener can kill the queue and crash other
listeners in the same queue? Shall we do some isolation?
yeah I think marcelo was asking about this above
https://github.com/apache/spark/pull/21356#discussion_r189100750
of course, we can't stop a listener from causing an OOM or launching 20
threads and hogging the CPU, but we could try for a little more isolation ...
> Not introduced by this PR, but I'm wondering why we only catch
InterruptedException? what about other exceptions?
NonFatal is already handled inside
[`ListenerBus.postToAll`](https://github.com/apache/spark/blob/d4a0895c628ca854895c3c35c46ed990af36ec61/core/src/main/scala/org/apache/spark/util/ListenerBus.scala#L81-L84)
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
