Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。
翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
FlinkKafkaConsumer セーブポイントによる停止に関する問題
レガシー を使用すると、システムスナップショットが有効になっていSCALINGる場合、アプリケーション FlinkKafkaConsumer が UPDATING、STOPPINGまたは で停止する可能性があります。この問題には公開されている修正がないため、この問題を軽減するために新しい
スナップショットを有効にFlinkKafkaConsumer
して を使用している場合、Flink ジョブがセーブポイントAPIリクエストで停止を処理すると、 が失敗し、 を報告するランタイムエラーが発生するFlinkKafkaConsumer
可能性がありますClosedException
。このような状況では、Flink アプリケーションが停止し、チェックポイント失敗と表示されます。