spark-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jaromir Vanek (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (SPARK-8393) JavaStreamingContext#awaitTermination() throws non-declared InterruptedException
Date Wed, 24 Jun 2015 09:49:05 GMT

    [ 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-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org


Mime
View raw message