You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Jaromir Vanek (JIRA)" <ji...@apache.org> on 2015/06/24 11:49:05 UTC

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

    [ https://issues.apache.org/jira/browse/SPARK-8393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599185#comment-14599185 ] 

Jaromir Vanek edited comment on SPARK-8393 at 6/24/15 9:48 AM:
---------------------------------------------------------------

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 {{awaitTerminatio}} method should be declared to throw {{InterruptedException}}.


was (Author: vanekjar):
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-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org