[
https://issues.apache.org/jira/browse/SPARK-8393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sean Owen updated SPARK-8393:
-----------------------------
Target Version/s: 2+
I agree, though there's a problem here. If we add this, then any existing use
of this code will fail to compile, since {{InterruptedException}} is a checked
exception. This is at best something that can be introduced for 2.x when
breaking changes are allowed.
Remind me, what happens in this case in Scala called from Java? surely you get
some {{RuntimeException}}? can you at least catch that and dig out the cause,
that is hopefully the {{InterruptedException}}?
However, even better, can't you just use {{awaitTerminationOrTimeout}}? that
doesn't require exception handling.
> 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: [email protected]
For additional commands, e-mail: [email protected]
