-
Type:
Bug
-
Status: Closed
-
Priority:
Blocker
-
Resolution: Fixed
-
Affects Version/s: None
-
Component/s: Connectors / Common
-
Labels:
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.
- blocks
-
FLINK-20114 Test Kafka Source based on the new Source API
-
- Open
-
-
FLINK-20157 SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission
-
- Closed
-
- links to