[
https://issues.apache.org/jira/browse/FLINK-17898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-17898:
---------------------------------
Description:
The {{collect(...)}} methods in {{SourceOutput}} currently declare that they
can {{trow Exception}}.
That was originally introduced, because it can be the case when pushing records
into the chain.
However, one can argue that the Source Reader that calls these methods is in no
way supposed to handle these exceptions, because they come from downstream
operator failures. Because of that, we should go for unchecked exceptions and
handle downstream exceptions via {{ExceptionInChainedOperatorException}}.
> Remove Exceptions from signatures of SourceOutput methods
> ---------------------------------------------------------
>
> Key: FLINK-17898
> URL: https://issues.apache.org/jira/browse/FLINK-17898
> Project: Flink
> Issue Type: Sub-task
> Components: API / DataStream
> Reporter: Stephan Ewen
> Priority: Blocker
> Fix For: 1.11.0
>
>
> The {{collect(...)}} methods in {{SourceOutput}} currently declare that they
> can {{trow Exception}}.
> That was originally introduced, because it can be the case when pushing
> records into the chain.
> However, one can argue that the Source Reader that calls these methods is in
> no way supposed to handle these exceptions, because they come from downstream
> operator failures. Because of that, we should go for unchecked exceptions and
> handle downstream exceptions via {{ExceptionInChainedOperatorException}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
