.
Regards,
Min
From: JING ZHANG
Sent: 08 July 2021 04:45
To: Tan, Min
Cc: Marco Villalobos ; user
Subject: [External] Re: State Processor API and existing state
Hi min,
Is the POJO state in an existed operator or a new added operator?
BTW, that would be great if you would like to give the code to
Table(
> AsyncSnapshotStrategySynchronicityBehavior.java:41)
>
> at org.apache.flink.runtime.state.heap.HeapSnapshotStrategy
> .newStateTable(HeapSnapshotStrategy.java:243)
>
> at org.apache.flink.runtime.state.heap.HeapRestoreOperation
> .createOrCheckStateForMetaInfo(HeapRestore
Sent: 29 June 2021 07:45
To: Marco Villalobos
Cc: user
Subject: [External] Re: State Processor API and existing state
Hi Marco,
> I assume that all the data within the checkpoint are stored within the given
> Savepoint. Is that assumption correct?
Yes
> I have not figured out how to corr
Hi Marco,
> I assume that all the data within the checkpoint are stored within the
given Savepoint. Is that assumption correct?
Yes
> I have not figured out how to correct / augment / fix the state though.
Can somebody please explain?
Please try this way.
1. Load old savepoint file, create Savepoin
