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

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

[~liufangqi] Since RocksDB incremenatl checkpoints already have enough 
information in checkpoint meta, could you try to use state processor API to 
achive your goal on that?

Your request actually has two problems, and I think they deserve two different 
discussion threads in dev mailling list:
 # Could we write meta state info in savepoint meta. [~dwysakowicz] what do you 
think of this especially you have already done the unified savepoint format 
work.
 # Whether we should persist addition info such as default value, 
reducingFunction to persist the whole state descriptor. I prefer to store them. 
[~tzulitai]  what do you think of this?

BTW, since many guys are on Christmas vacation, maybe we can launch discussions 
after new year's day.

> 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