flink任务日志告警:This does not compromise Flink's checkpoint integrity.

2021-04-20 文章 guoxb__...@sina.com
Hi all,
 
我这变flink任务日志发现,一直在报一个 告警,告警内容是:
   
 ```
  2021-04-21 09:13:07,218 WARN 
org.apache.flink.streaming.connectors.kafka.internal.KafkaFetcher [] - 
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遇到问题,请问下,大家有谁遇到过这个问题么,如何排查,烦请给些建议,万分感谢

所使用的flink版本:1.11
程序中设置的checkpoint interval=30s



guoxb__...@sina.com


flink任务日志告警:This does not compromise Flink's checkpoint integrity.

2021-04-20 文章 guoxb__...@sina.com
Hi all,
 
我这变flink任务日志发现,一直在报一个 告警,告警内容是:
   
 ```
  2021-04-21 09:13:07,218 WARN 
org.apache.flink.streaming.connectors.kafka.internal.KafkaFetcher [] - 
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遇到问题,请问下,大家有谁遇到过这个问题么,如何排查,烦请给些建议,万分感谢


guoxb__...@sina.com