[FLINK-20193] SourceCoordinator should catch exception thrown from SplitEnumerator.start()

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.11.3, 1.12.0
• Component/s: Connectors / Common
• Labels: pull-request-available
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Created: 17/Nov/20 15:11
• Updated: 12/Dec/20 11:57
• Resolved: 23/Nov/20 20:49

Description

This is a bug introduced in FLINK-18323 where we put SplitEnumrator.start() into the CoordinatorExecutor without catching exception. The fix is catching exception thrown from SplitEnumerator.start() and fail the job accordingly, just like the other method delegated to the CoordinatorExecutor.

Issue Links

• blocks: FLINK-20157 SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission
• blocks: FLINK-20114 Fix a few KafkaSource-related bugs
• links to: GitHub Pull Request #14104