[SPARK-8393] JavaStreamingContext#awaitTermination() throws non-declared InterruptedException

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.3.1
• Fix Version/s: 2.0.0
• Component/s: DStreams
• Target Version/s: 2.0.0
• Assignee: Sean R. Owen
• Reporter: Jaromir Vanek
• Created: 16/Jun/15 10:35
• Updated: 21/Apr/16 10:03
• Resolved: 21/Apr/16 10:03

Description

Call to JavaStreamingContext#awaitTermination() can throw InterruptedException which cannot be caught easily in Java because it's not declared in @throws(classOf[InterruptedException]) annotation.

This InterruptedException comes originally from ContextWaiter where Java ReentrantLock is used.

Issue Links

• links to: [Github] Pull Request #6969 (rekhajoshm)
• links to: [Github] Pull Request #12418 (srowen)