Usa Apache Beam con Managed Service per le applicazioni Apache Flink - Servizio gestito per Apache Flink

Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Usa Apache Beam con Managed Service per le applicazioni Apache Flink

Nota

Apache Beam non è supportato nella versione 1.19 di Apache Flink. A partire dal 27 giugno 2024, non esiste Apache Flink Runner compatibile per Flink 1.18. Per ulteriori informazioni, consulta la compatibilità delle versioni di Flink nella documentazione di Apache Beam. >

È possibile utilizzare il framework Apache Beam con l'applicazione del servizio gestito per Apache Flink per elaborare i dati di streaming. Le applicazioni del servizio gestito per Apache Flink che utilizzano Apache Beam utilizzano il runner Apache Flink per eseguire le pipeline Beam.

Per un tutorial sull'utilizzo di Apache Beam in un'applicazione del servizio gestito per Apache Flink, consulta Utilizzare CloudFormation con Managed Service per Apache Flink.

Limitazioni di Apache Flink runner con Managed Service for Apache Flink

Tieni presente quanto segue sull'utilizzo del runner Apache Flink con il servizio gestito per Apache Flink:

  • I parametri di Apache Beam non sono visualizzabili nella console del servizio gestito per Apache Flink.

  • Apache Beam è supportato solo nelle applicazioni del servizio gestito per Apache Flink che utilizzano Apache Flink versione 1.8 e successive. Apache Beam non è supportato nelle applicazioni del servizio gestito per Apache Flink che utilizzano Apache Flink versione 1.6.

Funzionalità di Apache Beam con Managed Service per Apache Flink

Il servizio gestito per Apache Flink supporta le stesse funzionalità di Apache Beam supportate dal runner Apache Flink. Per informazioni sulle funzionalità supportate dal runner Apache Flink, consulta la Matrice di compatibilità Beam.

È consigliabile testare l'applicazione Apache Flink nel servizio gestito per Apache Flink per verificare che tutte le funzionalità di cui l'applicazione ha bisogno siano supportate.