Amazon Managed Service para Apache Flink Amazon 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.
FlinkKafkaConsumer problema con stop with savepoint
Al utilizar la versión antigua, FlinkKafkaConsumer existe la posibilidad de que su aplicación se quede atascada STOPPING o que tenga SCALING habilitadas las instantáneas del sistema. UPDATING No hay ninguna solución publicada disponible para este problema
Si lo utiliza FlinkKafkaConsumer con las instantáneas habilitadas, existe la posibilidad de que, cuando el trabajo de Flink procese una API solicitud de parada con punto de guardado, FlinkKafkaConsumer se produzca un error de tiempo de ejecución que informe de una. ClosedException En estas condiciones, la aplicación Flink se bloquea y se manifiesta como puntos de control fallidos.
