View a markdown version of this page

Amazon Managed Service per Apache Flink 2.3 - Servizio gestito 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à.

Amazon Managed Service per Apache Flink 2.3

Managed Service for Apache Flink ora supporta Apache Flink versione 2.3.0. Questa sezione presenta le principali nuove funzionalità e modifiche introdotte con il supporto di Managed Service for Apache Flink di Apache Flink 2.3.0.

Nota

Se stai utilizzando 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 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.

Nota

L'aggiornamento da Flink 1.x a Flink 2.3 è un importante aggiornamento della versione con modifiche sostanziali e considerazioni sulla compatibilità dello stato. Prima di effettuare l'aggiornamento da 1.x, rivedi e. Modifiche e deprecazioni sostanziali Guida alla compatibilità dello stato per gli aggiornamenti di Flink 2.2

Apache Flink 2.3.0 introduce miglioramenti nell'API SQL, nella selezione adattiva delle partizioni per carichi di lavoro distorti e nella dashboard di Flink.

Funzionalità supportate e documentazione correlata

Funzionalità supportate

Description

Riferimento alla documentazione di Apache Flink

Miglioramenti SinkUpsertMaterializer e disturbi del changelog

Migliora l'ordine degli aggiornamenti durante la scrittura di flussi CDC o changelog negli upsert sink.

FLIP-558: Miglioramenti e disturbi SinkUpsertMaterializer del changelog

Application Management: 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, FLIP-560: Miglioramento delle capacità di gestione delle applicazioni

Selezione adattiva delle partizioni per StreamPartitioner

Opt-in ottimizzazione del throughput per Rebalance skewed e partizionatori. Rescale Disabilitato per impostazione predefinita; abilita con. taskmanager.network.adaptive-partitioner.enabled

FLIP-339: Selezione adattiva delle partizioni per StreamPartitioner

Nota

Puoi attivare le seguenti funzionalità inviando una richiesta di supporto:

Opt-in funzionalità e documentazione correlata

Opt-in features

Description

Riferimento alla documentazione di Apache Flink

Checkpoint di supporto durante il ripristino

Questa opzione è disattivata per impostazione predefinita in quanto è una funzionalità sperimentale in open source. Puoi richiedere di abilitarla per la tua applicazione utilizzando un caso di supporto.

FLIP-547: Checkpoint di supporto durante il ripristino

Per la documentazione sulla versione di Apache Flink 2.3.0, vedere Apache Flink Documentation v2.3.0. Per le note di rilascio di Flink 2.3, vedere Note di rilascio - Flink 2.3. https://nightlies.apache.org/flink/flink-docs-stable/release-notes/flink-2.3/

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 per preservare la retrocompatibilità con le versioni precedenti di 0 Apache Flink supportate e proteggere le applicazioni esistenti da una regressione comportamentale durante l'aggiornamento. Se desideri il nuovo comportamento equo, puoi attivarlo impostandolo in modo programmatico nel codice dell'applicazione. pipeline.watermark-alignment.max-drift Per ulteriori informazioni, consulta FLINK-37399: L'allineamento della filigrana impedisce ai lavori arretrati di utilizzare tutte le risorse.

Componenti per Amazon Managed Service per Apache Flink 2.3

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. https://docs.aws.amazon.com/managed-flink/latest/java/how-flink-connectors.html

Le seguenti funzionalità di Apache Flink 2.3 non sono supportate in Amazon Managed Service for Apache Flink:

  • Tabelle materializzate: istantanee di tabelle interrogabili e gestite in modo continuo.

  • Modifiche alla telemetria personalizzate: report metrici personalizzati e configurazioni di telemetria.

  • Flink Native S3 FileSystem (FLIP-555): implementazione nativa del file system S3 (sperimentale in open source)

  • ForSt State Backend: archiviazione a stato disaggregata (sperimentale in open source).

  • Java 21: supporto sperimentale in open source, non supportato in Managed Service for Apache Flink.

Flink 2.3 in Amazon Managed Service per Apache Flink non supporta le applicazioni Studio. Per ulteriori informazioni, consulta Creazione di un notebook Studio.