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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

guoxb__123@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遇到问题,请问下,大家有谁遇到过这个问题么,如何排查,烦请给些建议,万分感谢


[hidden email]