Creación de aplicaciones de Managed Service para Apache Flink con Apache Beam - 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.

Creación de aplicaciones de Managed Service para Apache Flink con Apache Beam

nota

Apache Beam no es compatible con la versión 1.19 de Apache Flink. A partir del 27 de junio de 2024, no había ningún Apache Flink Runner compatible con Flink 1.18. Para obtener más información, consulte la compatibilidad de las versiones de Flink en la documentación de Apache Beam. >

Puede usar el marco Apache Beam con su aplicación Managed Service para Apache Flink para procesar datos de streaming. Las aplicaciones de Managed Service para Apache Flink que utilizan Apache Beam, utilizan el ejecutor Apache Flink para ejecutar las canalizaciones de Beam.

Para obtener un tutorial sobre cómo usar Apache Beam en una aplicación de Managed Service para Apache Flink, consulte Utilización CloudFormation con Managed Service para Apache Flink.

Uso de Apache Beam con Managed Service para Apache Flink

Note lo siguiente sobre el uso del ejecutor de Apache Flink con Managed Service para Apache Flink:

  • Las métricas de Apache Beam no se pueden ver en la consola de Managed Service para Apache Flink.

  • Apache Beam solo es compatible con el servicio gestionado para las aplicaciones de Apache Flink que utilizan la versión 1.8 o superior de Apache Flink. Apache Beam no es compatible con las aplicaciones de Managed Service para Apache Flink que utilizan la versión 1.6 de Apache Flink.

Capacidades de haz

Managed Service para Apache Flink es compatible con las mismas capacidades de Apache Beam que el ejecutor Apache Flink. Para obtener información sobre las características compatibles con el ejecutor Apache Flink, consulte Beam Compatibility Matrix.

Le recomendamos que pruebe su aplicación Apache Flink en el servicio Managed Service para Apache Flink para comprobar que todas las características que su aplicación necesita sean compatibles.