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 1.20
El servicio gestionado para Apache Flink ahora es compatible con la versión 1.20.5 de Apache Flink. En esta sección se presentan las principales novedades y cambios introducidos al admitir el servicio gestionado para Apache Flink a Apache Flink 1.20.5. Se espera que Apache Flink 1.20 sea la última versión 1.x y una versión con compatibilidad a largo plazo (LTS) de Flink. Para obtener más información, consulte FLIP-458: Long-Term Compatibilidad con la versión final de la línea Apache Flink 1.x.
nota
Si utiliza una versión anterior compatible de Apache Flink y desea actualizar sus aplicaciones actuales a Apache Flink 1.20.5, 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.
Características admitidas
Apache Flink 1.20.5 introduce mejoras en las API de SQL, en las API y en el panel de control de Flink. DataStream
| Características admitidas | Description (Descripción) | Referencia de la documentación de Apache Flink |
|---|---|---|
| Agregue la cláusula DISTRIBUTED BY | Muchos motores de SQL exponen los conceptos de Partitioning, Bucketing oClustering. Flink 1.20 introduce el concepto de Bucketing en Flink. |
FLIP-376: Agregue la cláusula DISTRIBUTED BY |
| DataStream API: admite el procesamiento completo de particiones | Flink 1.20 introduce un soporte integrado para las agregaciones en transmisiones sin clave a través de la API de FullPartitionWindow. |
FLIP-380: Soporta el procesamiento completo de particiones en Non-keyed DataStream |
| Muestra la puntuación de sesgo de datos en el panel de Flink | El panel de Flink 1.20 ahora muestra información sobre el sesgo de datos. Cada operador de la UI del gráfico de tareas de Flink muestra una puntuación adicional de sesgo de datos. | FLIP-418: Muestra la puntuación de sesgo de datos en Flink Dashboard |
Para ver la documentación de la versión 1.20.5 de Apache Flink, consulte la documentación de Apache Flink v1.20.5 en el sitio web de
Componentes
| Componente | Versión |
|---|---|
| Java | 11 (recomendado) |
| Python |
3.11 |
| 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. |
| Apache Beam (solo aplicaciones Beam) |
A partir de la versión 2.70.0. Para obtener más información, consulte Compatibilidad de versiones de Flink |
Problemas conocidos
Servicio gestionado de Amazon para Apache Flink Studio
Amazon Managed Service para Apache Flink Studio utiliza los cuadernos de Apache Zeppelin para ofrecer una experiencia de desarrollo de interfaz única para desarrollar, depurar código y ejecutar aplicaciones de procesamiento de flujos de Apache Flink. Se requiere una actualización del intérprete Flink de Zeppelin para permitir la compatibilidad con Flink 1.20. Este trabajo está programado con la comunidad de Zeppelin. Actualizaremos estas notas cuando el trabajo esté finalizado. Se puede seguir utilizando Flink 1.15 con Amazon Managed Service para Apache Flink Studio. Para obtener más información, consulte Creación de un cuaderno de Studio.
Correcciones de errores adaptados
Amazon Managed Service para Apache Flink adapta correcciones de la comunidad de Flink para problemas críticos. La siguiente es una lista de las correcciones de errores que hemos adaptado:
| Enlace de JIRA de Apache Flink | Description (Descripción) |
|---|---|
| FLINK-35886 |
Esta solución soluciona un problema que provocaba una contabilidad incorrecta de los tiempos de espera de inactividad de las marcas de agua cuando hay una subtarea. backpressured/blocked |
