[
https://issues.apache.org/jira/browse/FLINK-17898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-17898.
----------------------------------
Resolution: Fixed
Fixed in
1.11.0 via
- 5365e40b59fec77de126054746257f17a718fb5b
1.12.0 (master) via
- 067d2f0cc5ad7c84d52997e62c115449a8f2c205
> 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
> Assignee: 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)
