Seleccione sus preferencias de cookies

Usamos cookies esenciales y herramientas similares que son necesarias para proporcionar nuestro sitio y nuestros servicios. Usamos cookies de rendimiento para recopilar estadísticas anónimas para que podamos entender cómo los clientes usan nuestro sitio y hacer mejoras. Las cookies esenciales no se pueden desactivar, pero puede hacer clic en “Personalizar” o “Rechazar” para rechazar las cookies de rendimiento.

Si está de acuerdo, AWS y los terceros aprobados también utilizarán cookies para proporcionar características útiles del sitio, recordar sus preferencias y mostrar contenido relevante, incluida publicidad relevante. Para aceptar o rechazar todas las cookies no esenciales, haga clic en “Aceptar” o “Rechazar”. Para elegir opciones más detalladas, haga clic en “Personalizar”.

FlinkKafkaConsumer problema con stop with savepoint

Modo de enfoque
FlinkKafkaConsumer problema con stop with savepoint - Managed Service para Apache Flink

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.

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.

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, por lo que le recomendamos que actualice a la nueva KafkaSourcepara mitigar 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.

PrivacidadTérminos del sitioPreferencias de cookies
© 2025, Amazon Web Services, Inc o sus afiliados. Todos los derechos reservados.