Use o Apache Beam com o Managed Service para aplicativos Apache Flink - Managed Service for Apache Flink

Anteriormente, o Amazon Managed Service for Apache Flink era conhecido 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á.

Use o Apache Beam com o Managed Service para aplicativos Apache Flink

nota

O Apache Beam não é suportado na versão 1.19 do Apache Flink. Em 27 de junho de 2024, não havia nenhum Apache Flink Runner compatível com o Flink 1.18. 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 com o serviço gerenciado para Apache Flink

Limitações do Apache Flink runner com serviço gerenciado para 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.

Recursos do Apache Beam com serviço gerenciado para 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.