[
https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463622#comment-17463622
]
Yun Tang commented on FLINK-25360:
----------------------------------
[~liufangqi], I think your concerns have two different problems:
# AggregatingStateDescriptor does not store the aggFunction on snapshot. This
indeed occurs for a long time, and I think this deserve a disscussion in
community mailling list. I prefer to store this in state descriptior.
# Checkpoint meta does not contains the state descriptors. This is only true
for savepoints, and checkpoints actually store the state descrtiptors, see
[MetadataV2V3SerializerBase
|https://github.com/apache/flink/blob/2b1a9dea74a334adb1fe890f024f4153ad11a985/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java#L318].
BTW, even in current status, state-processor-API could still work well to read
and modify the savepoints. It seems you have some additional requests, could
you share what feature you're implementing? Or why you must need the meta
stored in savepoint meta?
> 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)
