You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Ran Tao (Jira)" <ji...@apache.org> on 2022/12/15 04:18:00 UTC

[jira] [Created] (FLINK-30424) Add source operator restore readerState log to distinguish split is from newPartitions or split state

Ran Tao created FLINK-30424:
-------------------------------

             Summary: Add source operator restore readerState log to distinguish split is from newPartitions or split state
                 Key: FLINK-30424
                 URL: https://issues.apache.org/jira/browse/FLINK-30424
             Project: Flink
          Issue Type: Improvement
          Components: API / DataStream
    Affects Versions: 1.15.3, 1.16.0, 1.16.1
            Reporter: Ran Tao


When a job start firstly, we can find 'assignPartitions' from log。but if source recover from state, we can not distinguish the newPartitions is from timed discover thread or from reader task state.  

We can add a helper log to distinguish and confirm the reader using split state in recover situation.

 

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)