Jiangjie Qin created FLINK-20193: ------------------------------------ Summary: SourceCoordinator should catch exception thrown from SplitEnumerator.start() Key: FLINK-20193 URL: https://issues.apache.org/jira/browse/FLINK-20193 Project: Flink Issue Type: Bug Components: Connectors / Common Reporter: Jiangjie Qin
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.}} -- This message was sent by Atlassian Jira (v8.3.4#803005)