flink 检查点中存储了哪些数据？

Question

我有一个案例来处理重启 flink 作业。我需要使用检查点并使用它的元数据（kafkasource 输入的状态）来处理。目前，检查点自动使用元数据进行恢复，但我想从此文件中读取信息并处理某些内容。 文档只是介绍了一些方法，但没有介绍您的目标： dispose(),getCheckpointId(),getCheckpointProperties(),getMasterStates(),getOperatorStates().toString(),withProperties（CheckpointProperties 属性）`

Answer 1

状态处理器 API 将允许您处理检查点或保存点中的数据。

检查点和保存点包括确保有效的一次性语义所需的一切：

• 非键控状态（例如，kafka 偏移量、交易 ID）
• 广播状态
• 按键状态
• 定时器