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.
Servicio gestionado de Amazon 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 del Servicio gestionado para 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 la versión de Apache Flink integradas. 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 importante de la versión, con cambios importantes y consideraciones de compatibilidad entre estados. Antes de actualizar desde la versión 1.x, revise y. Cambios importantes y obsolescencias 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 sesgadas 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 los flujos de los CDC o del registro de cambios a los depositarios más inestables. |
FLIP-558: Mejoras y trastorno del registro de cambios SinkUpsertMaterializer |
API de lectura de administración de aplicaciones |
Nuevos puntos finales de solo lectura para la observabilidad a nivel de aplicación. Los puntos finales de escritura están deshabilitados en Amazon Managed Service para Apache Flink. |
FLIP-549: Administración de aplicaciones |
Selección de particiones adaptativa para StreamPartitioner |
Opt-in optimización del rendimiento para |
FLIP-339: Selección adaptativa de particiones 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 |
|---|---|---|
Punto de control de soporte durante la recuperación |
Está desactivado de forma predeterminada, ya que es una función experimental de código abierto. Puedes solicitar que se habilite para tu aplicación mediante un caso de soporte. |
FLIP-547: Punto de control de soporte durante la recuperación |
Para ver la documentación de la versión 2.3.0 de Apache Flink, consulte la documentación de Apache Flink v2.3.0.
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 atrasados 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 del comportamiento al actualizarse. Si quieres el nuevo comportamiento equitativo, puedes optar por ello configurándolo de pipeline.watermark-alignment.max-drift forma programática en el código de tu aplicación. Para obtener más información, consulta FLINK-37399: La alineación con marcas de agua evita que los trabajos atrasados utilicen todos los recursos.
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
Las siguientes funciones de Apache Flink 2.3 no son compatibles con Amazon Managed Service para Apache Flink:
Tablas materializadas: instantáneas de tablas consultables y mantenidas de forma continua.
Cambios de telemetría personalizados: indicadores métricos 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 de estado: almacenamiento de estado 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 en 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.
