Utilice Apache Beam con Managed Service para las aplicaciones de Apache Flink - 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.

Utilice Apache Beam con Managed Service para las aplicaciones de Apache Flink

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 Utilice CloudFormation.

Limitaciones del ejecutor Apache Flink con servicio gestionado 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 Apache Beam con servicio gestionado para Apache Flink

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.