Flink检查点状态始终处于进行中

Question

我使用数据流连接器KafkaSource和HbaseSinkFunction，使用kafka中的数据并将其写入hbase。

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

kafka中的数据已经成功写入hbase，但ui页面上的检查点状态仍然"正在进行中"，并且没有改变。

为什么会发生这种情况，以及如何应对

Flink版本：1.13.3，Hbase版本：1.3.1，Kafka版本：0.10.2

Answer 1

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

此外，您可以调整检查点间隔并观察它

当前检查点间隔为3s，时间相对较短。