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)

Reply via email to