Hi 首维， 你用的 Flink 版本是多少呢，然后你的 Checkpoint interval 设置的时间是多少，这两个信息提供一下。
Best, LakeShen 刘首维 <[email protected]> 于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 > > > 请问这个场景如何排查比较好 >
