FlinkKafkaConsumer masalah dengan berhenti dengan savepoint - Layanan Terkelola untuk Apache Flink

Amazon Managed Service untuk Apache Flink sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

FlinkKafkaConsumer masalah dengan berhenti dengan savepoint

Saat menggunakan legacy FlinkKafkaConsumer ada kemungkinan aplikasi Anda mungkin macet dalam UPDATE, STOPING atau SCALING, jika Anda mengaktifkan snapshot sistem. Tidak ada perbaikan yang dipublikasikan yang tersedia untuk masalah ini, oleh karena itu kami sarankan Anda meningkatkan ke yang baru KafkaSourceuntuk mengurangi masalah ini.

Jika Anda menggunakan snapshot FlinkKafkaConsumer with diaktifkan, ada kemungkinan saat pekerjaan Flink memproses stop dengan permintaan API savepoint, kesalahan FlinkKafkaConsumer dapat gagal dengan kesalahan runtime yang melaporkan file. ClosedException Dalam kondisi ini aplikasi Flink menjadi macet, bermanifestasi sebagai Pos Pemeriksaan Gagal.