Usar o Apache Beam com Managed Service for Apache Flink - Managed Service for Apache Flink

O Amazon Managed Service para Apache Flink (Amazon MSF) era conhecido anteriormente como Amazon Kinesis Data Analytics for Apache Flink.

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Usar o Apache Beam com Managed Service for Apache Flink

nota

Não há Apache Flink Runner compatível para o Flink 1.20. Para obter mais informações, consulte Compatibilidade de versão do Flink na documentação do Apache Beam. >

Você pode usar a estrutura Apache Beam com seu aplicativo Managed Service for Apache Flink para processar dados de streaming. Os aplicativos Managed for Apache Flink que usam o Apache Beam usam o Apache Flink runner para executar pipelines do Beam.

Para obter um tutorial sobre como usar o Apache Beam em um aplicativo Managed Service for Apache Flink, consulte. Use CloudFormation

Limpar o Apache Flink Runner com Managed Service for Apache Flink

Observe o seguinte sobre o uso do Apache Flink Runner com o Managed Service para Apache Flink:

  • As métricas do Apache Beam não podem ser visualizadas no console Managed Service for Apache Flink.

  • O Apache Beam só é compatível com aplicativos Managed Service for Apache Flink que usam o Apache Flink versão 1.8 e superior. O Apache Beam só é compatível com aplicativos Managed Service for Apache Flink que usam o Apache Flink versão 1.6.

Capacidades do Apache Beam com Managed Service for Apache Flink

O Managed Service for Apache Flink suporta os mesmos recursos do Apache Beam que o executor Apache Flink. Para obter informações sobre quais atributos são compatíveis com o executor Apache Flink, consulte a Matriz de compatibilidade do Beam.

Recomendamos que você teste seu aplicativo Apache Flink no serviço Managed Service for Apache Flink para verificar se oferecemos suporte a todos os recursos de que seu aplicativo precisa.