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 (Amazon MSF) se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.

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

nota

No existe un Apache Flink Runner compatible con Flink 1.20. Para obtener más información, consulte la compatibilidad de las versiones de Flink en la documentación de Apache Beam. >

Se 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 Uso de CloudFormation.

Limitaciones del ejecutor de Apache Flink 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 1.6.

Uso de Apache Beam con Managed Service 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.

Se recomienda 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.