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 warisan, FlinkKafkaConsumer ada kemungkinan aplikasi Anda mungkin macetUPDATING, STOPPING atauSCALING, 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 ketika pekerjaan Flink memproses stop dengan API permintaan savepoint, FlinkKafkaConsumer dapat gagal dengan kesalahan runtime yang melaporkan a. ClosedException Dalam kondisi ini aplikasi Flink menjadi macet, bermanifestasi sebagai Pos Pemeriksaan Gagal.