zhijiang created FLINK-6227:
-------------------------------
Summary: Introduce the DataConsumptionException for downstream
task failure
Key: FLINK-6227
URL: https://issues.apache.org/jira/browse/FLINK-6227
Project: Flink
Issue Type: Sub-task
Components: Network
Reporter: zhijiang
Priority: Minor
It is part of FLIP-1.
We define a new special exception to indicate the downstream task failure in
consuming upstream data.
The {{JobManager}} will receive and consider this special exception to
calculate the minimum connected sub-graph which is called {{FailoverRegion}}.
So the {{DataConsumptionException}} should contain {{ResultPartitionID}}
information for {{JobMaster}} tracking upstream executions.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
