FlinkKafkaConsumer 세이브 포인트 사용 중지 관련 문제 - Managed Service for Apache Flink

Amazon Managed Service for Apache Flink는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려졌습니다.

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

FlinkKafkaConsumer 세이브 포인트 사용 중지 관련 문제

FlinkKafkaConsumer 레거시를 사용할 때 응용 프로그램이 작동하지 STOPPING 않거나 시스템 스냅샷이 UPDATING 활성화되어 있는 SCALING 경우 문제가 발생할 수 있습니다. 이 문제에 대해 게시된 수정 사항이 없으므로 이 문제를 KafkaSource완화하려면 새 버전으로 업그레이드하는 것이 좋습니다.

스냅샷이 활성화된 상태로 를 사용하는 경우 Flink 작업에서 저장점 API 요청으로 중지를 처리할 때 실행이 실패하고 런타임 오류가 발생하여 a가 FlinkKafkaConsumer 보고될 수 있습니다. FlinkKafkaConsumer ClosedException 이러한 상황에서는 Flink 애플리케이션이 중단되고 실패한 체크포인트로 나타납니다.