Amazon Managed Service para Apache Flink Amazon (Amazon MSF) se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.
Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.
Problema de FlinkKafkaConsumer de detención con punto de guardado
Al utilizar la versión antigua de FlinkKafkaConsumer, existe la posibilidad de que la aplicación se bloquee al ACTUALIZAR, DETENER o ESCALAR si tiene habilitadas las instantáneas del sistema. No hay ninguna solución publicada disponible para este problema
Si se utiliza FlinkKafkaConsumer con las instantáneas habilitadas, existe la posibilidad de que, cuando el trabajo de Flink procese una detención con una solicitud de API de punto de guardado, FlinkKafkaConsumer falle con un error de tiempo de ejecución que indique ClosedException. En estas condiciones, la aplicación Flink se bloquea y se manifiesta como puntos de control fallidos.
