Flink 检查点状态始终在进行中答案

【问题标题】：Flink checkpoint status is always in progressFlink 检查点状态始终在进行中
【发布时间】：2021-12-22 02:30:30
【问题描述】：

我使用数据流连接器KafkaSource和HbaseSinkFunction，从kafka消费数据并写入hbase。

我这样启用检查点： env.enableCheckpointing(3000,CheckpointingMode.EXACTLY_ONCE);

kafka中的数据已经成功写入hbase，但是ui页面的checkpoints状态还是“in progress”，没有变化。

为什么会出现这种情况以及如何处理？

Flink 版本：1.13.3, Hbase版本：1.3.1, 卡夫卡版本：0.10.2

【问题讨论】：

【解决方案1】：

也许您可以发布完整的检查点配置参数。

另外，你可以调整检查点间隔并观察。

当前checkpoint间隔为3s，比较短。

【讨论】：