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

刘方奇 commented on FLINK-25360:
-----------------------------

[~yunta] THX for your reply.  We use state-processor-api to transform state 
now, but we find that we can not even build the state desc in any way. It seems 
like not friendly.
 # we can only get the typeSerializers or something that can not help we build 
a state desc (AggregatingStateDescriptor need the aggFunction).
 # even we just get the above, we can not get it easily, cause most of these 
are stored in the state file.

I think now the checkpoint meta do not have the power of self-described.

> 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