zoucao created FLINK-26723: ------------------------------ Summary: Fix the content of exception in SourceCoordinatorContext Key: FLINK-26723 URL: https://issues.apache.org/jira/browse/FLINK-26723 Project: Flink Issue Type: Improvement Components: Runtime / Coordination Reporter: zoucao
the exception in `SourceCoordinatorContext#SourceCoordinatorContext` will always be "Cannot assign splits null to subtask xxx because the subtask is not registered." We should fix it by using splits info. [see|https://github.com/apache/flink/blob/ccbb05ea4f11aac51103cadd13a6a2e38e319e8b/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java#L202] -- This message was sent by Atlassian Jira (v8.20.1#820001)