Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.
Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
FlinkKafkaConsumer Problem mit Stop with Savepoint
Wenn Sie die FlinkKafkaConsumer Legacy-Version verwenden, besteht die Möglichkeit, dass Ihre Anwendung hängen bleibtUPDATING, STOPPING oderSCALING, wenn Sie System-Snapshots aktiviert haben. Für dieses Problem
Wenn Sie den FlinkKafkaConsumer mit aktivierten Snapshots verwenden, besteht die Möglichkeit, dass der Flink-Job, wenn er eine API Stop-With-Savepoint-Anfrage verarbeitet, fehlschlägt und ein Laufzeitfehler mit der FlinkKafkaConsumer Meldung a auftritt. ClosedException Unter diesen Bedingungen bleibt die Flink-Anwendung hängen, was sich als Fehlgeschlagene Checkpoints äußert.
