[ 
https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463660#comment-17463660
 ] 

Yun Tang commented on FLINK-25360:
----------------------------------

It seems you're trying to read checkpoint to modify previous checkpoint without 
knowing the jobgraph (does not know what the operator is), right? If only wants 
to change the max paralleilsm, things could be much simpler.

 

Except from the agg function, what else do you need?

> Add State Desc to CheckpointMetadata
> ------------------------------------
>
>                 Key: FLINK-25360
>                 URL: https://issues.apache.org/jira/browse/FLINK-25360
>             Project: Flink
>          Issue Type: Improvement
>          Components: Runtime / Checkpointing, Runtime / State Backends
>            Reporter: 刘方奇
>            Priority: Major
>         Attachments: image-2021-12-17-20-01-42-423.png
>
>
> Now we can't get the State Descriptor info in the checkpoint meta. Like the 
> case if we use state-processor-api to load state then rewrite state, we can't 
> flexible use the state. 
> Maybe there are other cases we need the State Descriptor, so can we add this 
> info?



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to