Informazioni sulle versioni precedenti del servizio gestito per Apache Flink - Servizio gestito per Apache Flink
Utilizzo del connettore di flussi Apache Flink Kinesis con versioni precedenti di Apache FlinkCreazione di applicazioni con Apache Flink 1.8.2Creazione di applicazioni con Apache Flink 1.6.2Aggiornamento di applicazioniConnettori disponibili in Apache Flink 1.6.2 e 1.8.2

Il servizio gestito 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à.

Informazioni sulle versioni precedenti del servizio gestito per Apache Flink

Questo argomento contiene informazioni sull'utilizzo del servizio gestito per Apache Flink con versioni precedenti di Apache Flink. Le versioni di Apache Flink supportate dal servizio gestito per Apache Flink sono 1.15.2 (consigliata), 1.13.2, 1.11.1, 1.8.2 e 1.6.2.

Ti consigliamo di utilizzare l'ultima versione supportata di Apache Flink con la tua applicazione del servizio gestito per Apache Flink. Apache Flink 1.15.2 presenta le seguenti funzionalità:

  • Supporto per API ed SQL delle tabelle di Apache Flink

  • Supporto per applicazioni Python.

  • Supporto per Java versione 11 e qualsiasi versione di Scala

  • Un modello di memoria migliorato

  • Ottimizzazioni RockSDB per una maggiore stabilità delle applicazioni

  • Supporto per lo strumento di gestione attività e le tracce di stack nel pannello di controllo di Apache Flink.

Questo argomento contiene le sezioni seguenti:

Utilizzo del connettore di flussi Apache Flink Kinesis con versioni precedenti di Apache Flink

Il connettore di flussi Apache Flink Kinesis non era incluso in Apache Flink prima della versione 1.11. Affinché l'applicazione possa utilizzare il connettore Apache Flink Kinesis con le versioni precedenti di Apache Flink, è necessario scaricare, compilare e installare la versione di Apache Flink utilizzata dall'applicazione. Questo connettore serve per utilizzare i dati di un flusso Kinesis utilizzato come origine dell'applicazione o per scrivere dati su un flusso Kinesis utilizzato per l'output dell'applicazione.

Nota

Assicurati di creare il connettore con KPL versione 0.14.0 o successiva.

Per scaricare e installare il codice di origine di Apache Flink 1.8.2, procedi come segue:

  1. Assicurati di avere installato Apache Maven e che la variabile di ambiente JAVA_HOME punti a un JDK anziché a un JRE. Puoi testare la tua installazione di Apache Maven con il comando seguente:

    mvn -version

  2. Scarica il codice di origine di Apache Flink 1.8.2:

    wget https://archive.apache.org/dist/flink/flink-1.8.2/flink-1.8.2-src.tgz

  3. Decomprimi il codice di origine di Apache Flink:

    tar -xvf flink-1.8.2-src.tgz

  4. Passa alla directory del codice di origine di Apache Flink:

    cd flink-1.8.2

  5. Compila e installa Apache Flink:

    mvn clean install -Pinclude-kinesis -DskipTests
    Nota

    Se stai compilando Flink su Microsoft Windows, devi aggiungere il parametro -Drat.skip=true.

Creazione di applicazioni con Apache Flink 1.8.2

Questa sezione contiene informazioni sui componenti utilizzati per creare applicazioni del servizio gestito per Apache Flink compatibili con Apache Flink 1.8.2.

Utilizza le seguenti versioni dei componenti per il servizio gestito per Apache Flink:

Componente Versione
Java 1.8 (consigliata)
Apache Flink 1.8.2
Servizio gestito per Apache Flink per il runtime di Flink (aws-kinesisanalytics-runtime) 1.0.1
Connettori Flink del servizio gestito per Apache Flink (aws-kinesisanalytics-flink) 1.0.1
Apache Maven 3.1

Per compilare un'applicazione utilizzando Apache Flink 1.8.2, esegui Maven con il seguente parametro:

mvn package -Dflink.version=1.8.2

Per un esempio di file pom.xml per un'applicazione del servizio gestito per Apache Flink che utilizza Apache Flink 1.8.2, consulta l'applicazione introduttiva del servizio gestito per Apache Flink 1.8.2.

Per informazioni su come creare e utilizzare il codice applicativo per un'applicazione del servizio gestito per Apache Flink, consulta Creazione di applicazioni.

Creazione di applicazioni con Apache Flink 1.6.2

Questa sezione contiene informazioni sui componenti utilizzati per creare applicazioni del servizio gestito per Apache Flink compatibili con Apache Flink 1.6.2.

Utilizza le seguenti versioni dei componenti per il servizio gestito per Apache Flink:

Componente Versione
Java 1.8 (consigliata)
AWS SDK Java 1.11.379
Apache Flink 1.6.2
Servizio gestito per Apache Flink per il runtime di Flink (aws-kinesisanalytics-runtime) 1.0.1
Connettori Flink del servizio gestito per Apache Flink (aws-kinesisanalytics-flink) 1.0.1
Apache Maven 3.1
Apache Beam Non supportato con Apache Flink 1.6.2.
Nota

Quando utilizzi il servizio gestito per il runtime di Apache Flink versione 1.0.1, devi specificare la versione di Apache Flink nel file pom.xml anziché utilizzare il parametro -Dflink.version durante la compilazione del codice dell'applicazione.

Per un esempio di file pom.xml per un'applicazione del servizio gestito per Apache Flink che utilizza Apache Flink 1.6.2, consulta l'applicazione introduttiva del servizio gestito per Apache Flink 1.6.2.

Per informazioni su come creare e utilizzare il codice applicativo per un'applicazione del servizio gestito per Apache Flink, consulta Creazione di applicazioni.

Aggiornamento di applicazioni

Per aggiornare la versione di un'applicazione del servizio gestito per Apache Flink, è necessario aggiornare il codice dell'applicazione, eliminare l'applicazione precedente e creare una nuova applicazione con il codice aggiornato. Per farlo, esegui le operazioni seguenti:

  • Cambia le versioni del runtime e dei connettori Flink del servizio gestito per Apache Flink (aws-kinesisanalytics-flink) nel file pom.xml dell'applicazione a 1.1.0.

  • Rimuovi la proprietà flink.version dal file pom.xml dell'applicazione. Fornirai questo parametro quando compilerai il codice dell'applicazione nel passaggio successivo.

  • Ricompila il codice dell'applicazione tramite il comando seguente:

    mvn package -Dflink.version=1.15.3

  • Elimina l'applicazione esistente. Crea nuovamente l'applicazione e scegli Apache Flink 1.15.2 (versione consigliata) per il runtime dell'applicazione.

Nota

Non è possibile utilizzare snapshot delle versioni precedenti dell'applicazione.

Connettori disponibili in Apache Flink 1.6.2 e 1.8.2

Il framework Apache Flink contiene connettori per l'accesso ai dati da una varietà di origini.