You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@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)