[
https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463684#comment-17463684
]
刘方奇 commented on FLINK-25360:
-----------------------------
[~yunta] Yeah, your understand is right, but changing the max paralleilsm seems
like not simple, cause we need to rewrite the keyed state(we may even need to
rewrite the operator state, on current state-processor-api version).
Actually we need all the info that used to build the
org.apache.flink.api.common.state.StateDescriptor object. For example, state
type (list / map or reduce), TypeSerializer, default value etc.
BTW, how we can mock the raw state generate?
> 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)
