Hello,
Let me share my views on this issue, correct me if there is anything wrong.
To get a state handle, you have to create a StateDescriptor. This holds the
name of the state, the type of the values that the state holds and other
information. You could pass the type serializer or the type
Hello,
I have been trying to understand how serialization works for the Flink Heap
Keyed state backend when a checkpoint happens. I want to know how Flink knows
which type of serializer to use to serialize the values for different states
during the snapshot.
I have debugged both RocksDB and
