[FLINK-12458] Introduce PartitionConnectionException for unreachable producer

• Type: Sub-task
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 09/May/19 07:03
• Updated: 23/May/19 16:20
• Resolved: 23/May/19 16:18

Description

If the consumer can not establish a connection to remote task executor, which might indicate the remote task executor is not reachable. We could wrap this connection exception into new proposed `PartitionConnectionException` which also extends `PartitionException`, then the job master would decide whether to restart the upstream region to re-producer partition data.

Issue Links

• relates to: FLINK-6227 Introduce the abstract PartitionException for downstream task failure
• links to: GitHub Pull Request #8509