[
https://issues.apache.org/jira/browse/SPARK-8393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599185#comment-14599185
]
Jaromir Vanek commented on SPARK-8393:
--------------------------------------
I think the suggested workaround is fine for the current 1.x version of Spark.
So updating the documentation would be proper solution to prevent other
developers from unexpected problems.
But in the next major version of Spark it should be fixed properly and
`awaitTermination` method should be declared to throw `InterruptedException`.
> JavaStreamingContext#awaitTermination() throws non-declared
> InterruptedException
> --------------------------------------------------------------------------------
>
> Key: SPARK-8393
> URL: https://issues.apache.org/jira/browse/SPARK-8393
> Project: Spark
> Issue Type: Bug
> Components: Streaming
> Affects Versions: 1.3.1
> Reporter: Jaromir Vanek
> Priority: Trivial
>
> 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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
