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à.
Servizio gestito Amazon per Apache Flink 2.3
Managed Service for Apache Flink ora supporta Apache Flink versione 2.3.0. Questa sezione presenta le nuove funzionalità e le modifiche principali introdotte con il supporto di Managed Service for Apache Flink di Apache Flink 2.3.0.
Nota
Se utilizzi una versione precedente supportata di Apache Flink e desideri aggiornare le tue applicazioni esistenti ad Apache Flink 2.3.0, puoi farlo utilizzando gli aggiornamenti di 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.
Nota
L'aggiornamento da Flink 1.x a Flink 2.3 è un aggiornamento di versione importante che comporta modifiche sostanziali e considerazioni sulla compatibilità degli stati. Prima di eseguire l'aggiornamento dalla 1.x, rivedi e. Interruzione delle modifiche e delle deprecazioni Guida alla compatibilità dello stato per gli aggiornamenti di Flink 2.2
Funzionalità supportate
Apache Flink 2.3.0 introduce miglioramenti nell'API SQL, nella selezione adattiva delle partizioni per carichi di lavoro inclinati e nella dashboard Flink.
Funzionalità supportate |
Description |
Riferimento alla documentazione di Apache Flink |
|---|---|---|
Miglioramenti SinkUpsertMaterializer e disturbo del registro delle modifiche |
Migliora l'ordine degli aggiornamenti durante la scrittura di flussi CDC o changelog su upsert sink. |
FLIP-558: Miglioramenti e disturbo SinkUpsertMaterializer del registro delle modifiche |
Gestione delle applicazioni: leggi le API |
Nuovi endpoint di sola lettura per l'osservabilità a livello di applicazione. Gli endpoint di scrittura sono disabilitati in Amazon Managed Service for Apache Flink. |
FLIP-549: Gestione delle applicazioni |
Selezione adattiva delle partizioni per StreamPartitioner |
Opt-in ottimizzazione del throughput per |
FLIP-339: Selezione adattiva delle partizioni per StreamPartitioner |
Opt-in features |
Description |
Riferimento alla documentazione di Apache Flink |
|---|---|---|
Supporta il checkpoint durante il ripristino |
Questa funzionalità è disabilitata per impostazione predefinita in quanto è una funzionalità sperimentale in open source. Puoi richiedere di abilitarla per la tua applicazione utilizzando un case di supporto. |
Per la documentazione della versione di Apache Flink 2.3.0, vedere Apache
Modifiche ad Amazon Managed Service per Apache Flink con Apache Flink 2.3
L'allineamento della filigrana (impostazione predefinita) è stato mantenuto
Apache Flink 2.3 modifica il comportamento predefinito dell'allineamento delle filigrane per evitare che i lavori arretrati consumino tutte le risorse a valle. In Amazon Managed Service for Apache Flink, il valore predefinito di pipeline.watermark-alignment.max-drift è impostato 0 per preservare la retrocompatibilità con le versioni precedenti di Apache Flink supportate e proteggere le applicazioni esistenti da una regressione comportamentale durante l'aggiornamento. Se desideri il nuovo comportamento di equità, puoi attivarlo impostandolo a livello di codice nel codice dell'applicazione. pipeline.watermark-alignment.max-drift Per ulteriori informazioni, consulta FLINK-37399: L'allineamento della filigrana impedisce che i lavori arretrati utilizzino
Componenti
Componente |
Versione |
|---|---|
Java |
17 (consigliato) |
Python |
3.12 |
Kinesis Data Analytics Flink Runtime (aws-kinesisanalytics-runtime) |
1.2.0 |
Connettori |
Per informazioni sui connettori disponibili, consulta Connettori Apache Flink. |
Funzionalità sperimentali e non supportate
Le seguenti funzionalità di Apache Flink 2.3 non sono supportate in Amazon Managed Service per Apache Flink:
Tabelle materializzate: istantanee di tabelle interrogabili e gestite in modo continuo.
Modifiche telemetriche personalizzate: report metrici personalizzati e configurazioni di telemetria.
-
Flink Native S3 FileSystem (FLIP-555): implementazione del file system S3 nativo (sperimentale in open source)
-
ForSt State Backend: archiviazione a stati disaggregata (sperimentale in open source).
-
Java 21: supporto sperimentale in open source, non supportato in Managed Service for Apache Flink.
Servizio gestito da Amazon per Apache Flink Studio
Flink 2.3 in Amazon Managed Service for Apache Flink non supporta le applicazioni Studio. Per ulteriori informazioni, consulta Creazione di un notebook Studio.
