FlinkKafkaConsumer savepoint での停止に関する問題

レガシーを使用する場合 FlinkKafkaConsumer 、システムスナップショットが有効になっている場合SCALING、アプリケーションが UPDATINGSTOPPINGまたは にスタックする可能性があります。この問題には公開された修正がないため、この問題を軽減KafkaSourceするために新しい にアップグレードすることをお勧めします。

スナップショットを有効にFlinkKafkaConsumerして を使用している場合、Flink ジョブが savepoint APIリクエストで停止を処理すると、 が失敗FlinkKafkaConsumerし、 を報告するランタイムエラーが発生する可能性がありますClosedException。このような状況では、Flink アプリケーションが停止し、チェックポイント失敗と表示されます。