[SPARK-26046] Add a way for StreamingQueryManager to remove all listeners

• Type: Task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.4.0
• Fix Version/s: 3.0.0
• Component/s: Structured Streaming
• Assignee: Unassigned
• Reporter: Mukul Murthy
• Created: 13/Nov/18 21:50
• Updated: 05/Sep/19 21:29
• Resolved: 05/Sep/19 21:29

Description

StreamingQueryManager should have a way to clear out all listeners. There's addListener(listener) and removeListener(listener), but not removeAllListeners. We should expose a new method removeAllListeners() that calls listenerBus.removeAllListeners (added here: https://github.com/apache/spark/commit/9690eba16efe6d25261934d8b73a221972b684f3) listListeners() that can be used to remove listeners.

Issue Links

• links to: GitHub Pull Request #25518