Committing offsets to Kafka takes longer than the checkpoint interval.

[刘首维]

Hi all,



今天发现有一个作业日志中连续打印下面这个报警

"Committing offsets to Kafka takes longer than the checkpoint interval. Skipping commit of previous offsets because newer complete checkpoint offsets are available. This does not compromise Flink's checkpoint integrity."


导致作业卡住无法继续消费Kafka topic


请问这个场景如何排查比较好

[LakeShen]

Hi 首维，

你用的 Flink 版本是多少呢，然后你的 Checkpoint interval 设置的时间是多少，这两个信息提供一下。

Best,
LakeShen



刘首维 <[hidden email]> 于2020年4月28日周二 下午6:28写道：

> Hi all,
>
>
>
> 今天发现有一个作业日志中连续打印下面这个报警
>
> "Committing offsets to Kafka takes longer than the checkpoint interval.
> Skipping commit of previous offsets because newer complete checkpoint
> offsets are available. This does not compromise Flink's checkpoint
> integrity."
>
>
> 导致作业卡住无法继续消费Kafka topic
>
>
> 请问这个场景如何排查比较好
>