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 2.3
El servicio gestionado para Apache Flink ahora es compatible con la versión 2.3.0 de Apache Flink. En esta sección se presentan las principales novedades y cambios introducidos con la compatibilidad de Managed Service for Apache Flink con Apache Flink 2.3.0.
nota
Si utiliza una versión anterior compatible de Apache Flink y desea actualizar sus aplicaciones actuales a Apache Flink 2.3.0, puede hacerlo mediante las actualizaciones de versión integradas de Apache Flink. Para obtener más información, consulte Uso de actualizaciones de versión locales para Apache Flink. Con las actualizaciones de versión locales, se retiene la trazabilidad de las aplicaciones con respecto a un único ARN en todas las versiones de Apache Flink, incluidas las instantáneas, los registros, las métricas, las etiquetas, las configuraciones de Flink y más.
nota
La actualización de Flink 1.x a Flink 2.3 es una actualización de versión importante que implica cambios importantes y consideraciones de compatibilidad de estado. Antes de actualizar desde la versión 1.x, revise y. Cambios y desaprobaciones de última hora Guía de compatibilidad estatal para las actualizaciones de Flink 2.2
Características admitidas
Apache Flink 2.3.0 introduce mejoras en la API de SQL, la selección adaptativa de particiones para cargas de trabajo asimétricas y el panel de control de Flink.
Características admitidas |
Description (Descripción) |
Referencia de la documentación de Apache Flink |
|---|---|---|
Mejoras y trastorno del registro de cambios SinkUpsertMaterializer |
Mejora el orden de las actualizaciones al escribir las transmisiones de los CDC o del registro de cambios en los sumideros de upsert. |
FLIP-558: Mejoras y trastornos del registro de cambios SinkUpsertMaterializer |
Gestión de aplicaciones: lee las API |
Nuevos puntos finales de solo lectura para la observabilidad a nivel de aplicación. Los puntos de enlace de escritura están deshabilitados en Amazon Managed Service para Apache Flink. |
FLIP-549: Administración de aplicaciones,FLIP-560: Mejora de |
Selección de particiones adaptativas para StreamPartitioner |
Opt-in optimización del rendimiento para particionadores |
FLIP-339: Selección de particiones adaptativa para StreamPartitioner |
nota
Se puede optar por las siguientes funciones al enviar un caso de soporte:
Opt-in features |
Description (Descripción) |
Referencia de la documentación de Apache Flink |
|---|---|---|
Support checkpoint durante la recuperación |
Esto está deshabilitado de forma predeterminada, ya que es una función experimental en código abierto. Puede solicitar su activación para su aplicación mediante un caso de soporte. |
Para ver la documentación de la versión 2.3.0 de Apache Flink, consulte la documentación de Apache Flink
Cambios en Amazon Managed Service para Apache Flink con Apache Flink 2.3
Se conserva la alineación de las marcas de agua por defecto
Apache Flink 2.3 cambia el comportamiento predeterminado de la alineación de las marcas de agua para evitar que los trabajos pendientes consuman todos los recursos posteriores. En Amazon Managed Service para Apache Flink, el valor predeterminado de pipeline.watermark-alignment.max-drift se establece en 0 para preservar la compatibilidad con versiones anteriores de Apache Flink compatibles y proteger las aplicaciones existentes de una regresión de comportamiento al actualizarse. Si desea adoptar el nuevo comportamiento de imparcialidad, puede activarlo configurándolo mediante pipeline.watermark-alignment.max-drift programación en el código de su aplicación. Para obtener más información, consulte FLINK-37399: La alineación de marcas de agua evita que los trabajos pendientes utilicen todos los
Componentes
Componente |
Versión |
|---|---|
Java |
17 (recomendado) |
Python |
3.12 |
El tiempo de ejecución de Flink de Kinesis Data Analytics (aws-kinesisanalytics-runtime) |
1.2.0 |
Connectors |
Para obtener información sobre los conectores disponibles, consulte los conectores de Apache Flink. |
Funciones experimentales y no compatibles
Amazon Managed Service para Apache Flink no admite las siguientes funciones de Apache Flink 2.3:
Tablas materializadas: instantáneas de tablas consultables que se mantienen continuamente.
Cambios de telemetría personalizados: indicadores de métricas y configuraciones de telemetría personalizados.
-
Flink Native S3 FileSystem (FLIP-555): implementación del sistema de archivos S3 nativo (experimental en código abierto)
-
ForSt Backend estatal: almacenamiento de estados desagregado (experimental en código abierto).
-
Java 21: soporte experimental en código abierto, no compatible con Managed Service para Apache Flink.
Amazon Managed Service para Apache Flink Studio
Flink 2.3 de Amazon Managed Service para Apache Flink no es compatible con las aplicaciones de Studio. Para obtener más información, consulte Creación de un cuaderno de Studio.
