FlinkKafkaConsumer 與保存點停止問題 - Managed Service for Apache Flink

Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

FlinkKafkaConsumer 與保存點停止問題

使用舊版時 FlinkKafkaConsumer ，您的應用程序可能會卡在中UPDATING，STOPPING或者SCALING，如果您啟用了系統快照。此問題沒有已發佈的修正程式可用，因此建議您升級KafkaSource至新版本以減輕此問題。

如果您正在使用啟FlinkKafkaConsumer用快照的情況下，Flink 工作可能會使用保存點API請求處理停止，則FlinkKafkaConsumer可能會失敗並報告執行時期錯誤。ClosedException在這些情況下，Flink 應用程式會卡住，並顯示為失敗的檢查點。