apache kafka – What data is stored in flink checkpoints?
I have a case to handle restart flink job. I need use checkpointing and use metadata (state of kafkasource input) of it to process. Currently, checkpointing auto use metadata to recovery, but i wanna read info from this file and process something.
Documents just intro some method but not your goal:
dispose(),getCheckpointId(),getCheckpointProperties(),getMasterStates(),getOperatorStates().toString(),withProperties(CheckpointProperties properties)`
Read more here: Source link