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à.
Amazon Managed Service per Apache Flink 1.20
Managed Service for Apache Flink ora supporta Apache Flink versione 1.20.5. Questa sezione presenta le principali nuove funzionalità e modifiche introdotte con il supporto di Managed Service for Apache Flink di Apache Flink 1.20.5. Apache Flink 1.20 dovrebbe essere l'ultima versione 1.x e una versione di supporto a lungo termine (LTS) di Flink. Per ulteriori informazioni, vedere FLIP-458: Long-Term Supporto per la versione finale di Apache Flink 1.x Line.
Nota
Se si utilizza una versione precedente supportata di Apache Flink e si desidera aggiornare le applicazioni esistenti ad Apache Flink 1.20.5, è possibile farlo utilizzando gli aggiornamenti della versione di Apache Flink sul posto. Per ulteriori informazioni, consulta Usa gli aggiornamenti di versione sul posto per Apache Flink. Con gli aggiornamenti delle versioni sul posto, mantieni la tracciabilità delle applicazioni rispetto a un singolo ARN tra le versioni di Apache Flink, inclusi snapshot, log, metriche, tag, configurazioni Flink e altro ancora.
Funzionalità supportate
Apache Flink 1.20.5 introduce miglioramenti nelle API SQL, nelle API e nella dashboard di Flink. DataStream
| Funzionalità supportate | Description | Riferimento alla documentazione di Apache Flink |
|---|---|---|
| Aggiungere la clausola DISTRIBUTED BY | Molti motori SQL espongono i concetti diPartitioning,Bucketing, o. Clustering Flink 1.20 introduce il concetto di a Flink. Bucketing |
FLIP-376: Aggiungi la clausola DISTRIBUTED BY |
| DataStream API: supporta l'elaborazione completa delle partizioni | Flink 1.20 introduce il supporto integrato per le aggregazioni su stream senza chiave tramite l'API. FullPartitionWindow |
FLIP-380: supporta l'elaborazione completa delle partizioni su Non-keyed DataStream |
| Mostra il punteggio di distorsione dei dati su Flink Dashboard | La dashboard di Flink 1.20 ora mostra le informazioni sull'distorsione dei dati. Ogni operatore sull'interfaccia utente di Flink Job Graph mostra un punteggio aggiuntivo di distorsione dei dati. | FLIP-418: Mostra il punteggio di distorsione dei dati su Flink Dashboard |
Per la documentazione sulla versione di Apache Flink 1.20.5, consultate Apache Flink Documentation v1.20.5 sul sito Web di Apache Flink.
Componenti
| Componente | Versione |
|---|---|
| Java | 11 (consigliata) |
| Python |
3.11 |
| Kinesis Data Analytics Flink Runtime (aws-kinesisanalytics-runtime) | 1.2.0 |
| Connettori | Per informazioni sui connettori disponibili, consulta Connettori Apache Flink. https://docs.aws.amazon.com/managed-flink/latest/java/how-flink-connectors.html |
| Apache Beam (solo applicazioni Beam) |
Dalla versione 2.70.0. Per ulteriori informazioni, vedere Compatibilità delle versioni di Flink. |
Problemi noti
Amazon Managed Service per Apache Flink Studio
Amazon Managed Service per Apache Flink Studio utilizza i notebook Apache Zeppelin per fornire un'esperienza di sviluppo a interfaccia singola per lo sviluppo, il debug del codice e l'esecuzione di applicazioni di elaborazione di stream Apache Flink. È necessario un aggiornamento al Flink Interpreter di Zeppelin per abilitare il supporto di Flink 1.20. Questo lavoro è programmato con la comunità Zeppelin. Aggiorneremo queste note quando il lavoro sarà completato. Puoi continuare a utilizzare Flink 1.15 con Amazon Managed Service per Apache Flink Studio. Per ulteriori informazioni, consulta Creazione di un notebook Studio.
Correzioni di bug con backport
Amazon Managed Service for Apache Flink esegue il backport delle correzioni fornite dalla community di Flink per i problemi critici. Di seguito è riportato un elenco di correzioni di bug di cui abbiamo eseguito il backport:
| Collegamento Apache Flink JIRA | Description |
|---|---|
| FLINK-35886 |
Questa correzione risolve un problema che causava una contabilizzazione errata dei timeout di inattività della filigrana quando si verifica una sottoattività. backpressured/blocked |
