[FLINK-19535] SourceCoordinator should avoid fail job multiple times.

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.11.2
• Fix Version/s: 1.12.0, 1.11.3
• Component/s: Connectors / Common
• Labels: pull-request-available
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Created: 08/Oct/20 07:56
• Updated: 12/Dec/20 11:57
• Resolved: 24/Nov/20 12:20

Description

Currently the SourceCoordinator may invoke SourceCoordinatorContext#failJob() multiple times from the same instance. This may cause the job to failover multiple times unnecessarily. The SourceCoordinator should instead just fail the job once.

Issue Links

• links to: GitHub Pull Request #14158