[
https://issues.apache.org/jira/browse/FLINK-30424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-30424:
----------------------------
Description:
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. it's useful for debug and
was:
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.
> 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.16.0, 1.15.3, 1.16.1
> Reporter: Ran Tao
> Priority: Major
> Labels: pull-request-available
>
> 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. it's useful for debug and
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
