FlinkKafkaConsumer 使用 savepoint 停止时出现问题 - Managed Service for Apache Flink
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

FlinkKafkaConsumer 使用 savepoint 停止时出现问题

使用旧版 FlinkKafkaConsumer 时，您的应用程序可能会卡住 UPDATINGSCALING，STOPPING或者如果您启用了系统快照。没有针对此问题的已发布修复程序，因此我们建议您升级到新版本KafkaSource以缓解此问题。

如果您在FlinkKafkaConsumer启用快照的情况下使用的，则当 Flink 作业处理带有 savepoint API 请求的停止时，FlinkKafkaConsumer可能会失败，并报告运行时错误。ClosedException在这种情况下，Flink 应用程序会卡住，表现为失败的检查点。