FlinkKafkaConsumer issue with stop with savepoint - Managed Service for Apache Flink
Services or capabilities described in Amazon Web Services documentation might vary by Region. To see the differences applicable to the China Regions, see Getting Started with Amazon Web Services in China (PDF).

Amazon Managed Service for Apache Flink was previously known as Amazon Kinesis Data Analytics for Apache Flink.

FlinkKafkaConsumer issue with stop with savepoint

When using the legacy FlinkKafkaConsumer there is a possibility your application may get stuck in UPDATING, STOPPING or SCALING, if you have system snapshots enabled. There is no published fix available for this issue, therefore we recommend you upgrade to the new KafkaSource to mitigate this issue.

If you are using the FlinkKafkaConsumer with snapshots enabled, there is a possibility when the Flink job processes a stop with savepoint API request, the FlinkKafkaConsumer can fail with a runtime error reporting a ClosedException. Under these conditions the Flink application becomes stuck, manifesting as Failed Checkpoints.