Github user squito commented on the issue:
https://github.com/apache/spark/pull/21356
I pushed an update which only removes the listener which was active at the
interrupt. Note that is not the same thing as the listener which *caused* the
interrupt, necessarily -- we have no idea who caused the interrupt really, but
I guess it would be rather contrived for another Thread to interrupt the event
queue threads.
I'm not sure if I should leave some more guards against interrupts as well
-- eg. check the interrupted status before posting the event to a specific
listener, and if its set throwing InterruptedException, and leaving the generic
handling of InterruptedException in the AsyncEventQueue, to shut the queue down
entirely if there is any interrupt *outside* of a posting to a listener.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
