Servizio gestito Amazon per Apache Flink 1.20

Modalità Focus

Servizio gestito Amazon per Apache Flink 1.20 - Servizio gestito per Apache Flink

Funzionalità supportate Componenti Problemi noti

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à.

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à.

Managed Service for Apache Flink ora supporta la versione 1.20.0 di Apache Flink. Questa sezione presenta le nuove funzionalità e le modifiche principali introdotte con il supporto di Managed Service for Apache Flink di Apache Flink 1.20.0. Apache Flink 1.20 dovrebbe essere l'ultima versione 1.x e una versione di Flink con supporto a lungo termine (LTS). Per ulteriori informazioni, consulta FLIP-458: Long-Term Support for the Final Release of Apache Flink 1.x Line.

Nota

Se utilizzi una versione precedente supportata di Apache Flink e desideri aggiornare le tue applicazioni esistenti ad Apache Flink 1.20.0, puoi farlo utilizzando gli aggiornamenti della versione di Apache Flink in loco. Per ulteriori informazioni, consulta Usa gli aggiornamenti di versione sul posto per Apache Flink. Con gli aggiornamenti di versione in loco, mantieni la tracciabilità delle applicazioni su un singolo ARN tra le versioni di Apache Flink, tra cui istantanee, log, metriche, tag, configurazioni Flink e altro ancora.

Funzionalità supportate

Apache Flink 1.20.0 introduce miglioramenti nell'SQL, nella dashboard e nella dashboard di Flink. APIs DataStream APIs

Funzionalità supportate e documentazione correlata
Funzionalità supportate	Descrizione	Riferimento alla documentazione di Apache Flink
Aggiungi la clausola DISTRIBUTED BY	Molti motori SQL espongono i concetti di `PartitioningBucketing`, o. `Clustering` Flink 1.20 introduce il concetto di to 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 flussi 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 sulla distorsione dei dati. Ogni operatore nell'interfaccia utente del grafico dei lavori di Flink mostra un punteggio aggiuntivo di distorsione dei dati.	FLIP-418: mostra il punteggio di distorsione dei dati sulla dashboard di Flink

Per la documentazione sulla versione di Apache Flink 1.20.0, consultate Apache Flink Documentation v1.20.0. Per le note di rilascio di Flink 1.20, consultate Release notes - Flink 1.20

Componenti

Componenti Flink 1.20
Componente	Versione
Java	11 (consigliata)
Python	3.11
Kinesis Data Analytics Flink Runtime () aws-kinesisanalytics-runtime	1.2.0
Connectors (Connettori)	Per informazioni sui connettori disponibili, consulta Connettori Apache Flink.
Apache Beam (solo applicazioni Beam)	Non esiste Apache Flink Runner compatibile per Flink 1.20. Per ulteriori informazioni, consulta Compatibilità delle versioni di Flink.

Problemi noti

Apache Beam

Al momento non esiste Apache Flink Runner compatibile per Flink 1.20 in Apache Beam. Per ulteriori informazioni, consulta Compatibilità delle versioni di Flink.

Servizio gestito Amazon per Apache Flink Studio

Amazon Managed Service for 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 flussi Apache Flink. È necessario un aggiornamento a 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à completo. 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 supporta le correzioni della community Flink per problemi critici. Di seguito è riportato un elenco di correzioni di bug di cui abbiamo eseguito il backport:

Correzioni di bug ripristinate
Collegamento Apache Flink JIRA	Descrizione
FLINK-35886	Questa correzione risolve un problema che causa una contabilizzazione errata dei timeout di inattività delle filigrane quando un'attività secondaria viene sottoposta a contropressione/blocco.