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)
