Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。
本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
FlinkKafkaConsumer 與保存點停止問題
使用舊版時,如 FlinkKafkaConsumer 果您啟用了系統快照,您的應用程序可能會卡在更新,停止或擴展中。此問
如果您正在啟用快照的情況下使用 FlinkKafkaConsumer
,Flink 作業可能會使用儲存點 API 請求處理停止,FlinkKafkaConsumer
可能會失敗並報告執行期錯誤 ClosedException
。在這些情況下,Flink 應用程式會卡住,並顯示為失敗的檢查點。