[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-6227:
Description:
It is part of FLIP-1.
We define a new abstract special exception called PartitionException
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-6227:
--
Labels: pull-request-available (was: )
> Introduce the DataConsumptionException for downstream
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-6227:
Component/s: Runtime / Coordination
> Introduce the DataConsumptionException for downstream task failure
>
