Informationen zu früheren Versionen für Managed Service für Apache Flink - Managed Service für Apache Flink
Verwenden des Apache Flink Kinesis Streams-Konnektor mit früheren Apache Flink-VersionenAnwendungen mit Apache Flink 1.8.2 erstellenErstellen von Anwendungen mit Apache Flink 1.6.2Aktualisieren von AnwendungenVerfügbare Konnektoren in Apache Flink 1.6.2 und 1.8.2

Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Informationen zu früheren Versionen für Managed Service für Apache Flink

Dieses Thema enthält Informationen zur Verwendung von Managed Service für Apache Flink mit älteren Versionen von Apache Flink. Die Versionen von Apache Flink, die Managed Service für Apache Flink unterstützt, sind 1.15.2 (empfohlen), 1.13.2, 1.11.1, 1.8.2 und 1.6.2.

Wir empfehlen, dass Sie die neueste unterstützte Version von Apache Flink mit Ihrer Anwendung Managed Service für Apache Flink verwenden. Apache Flink Version 1.15.2 hat die folgenden Funktionen:

  • Support für Apache Flink Tabellen-API und SQL

  • Support für Python-Anwendungen.

  • Support für Java Version 11 und jede Scala-Version

  • Ein verbessertes Speichermodell

  • RocksDB-Optimierungen für erhöhte Anwendungsstabilität

  • Support für Taskmanager und Stack-Traces im Apache Flink-Dashboard.

Dieses Thema enthält die folgenden Abschnitte:

Verwenden des Apache Flink Kinesis Streams-Konnektor mit früheren Apache Flink-Versionen

Der Apache Flink Kinesis Streams-Konnektor war vor Version 1.11 nicht in Apache Flink enthalten. Damit Ihre Anwendung den Apache Flink Kinesis-Konnektor mit früheren Versionen von Apache Flink verwenden kann, müssen Sie die Version von Apache Flink, die Ihre Anwendung verwendet, herunterladen, kompilieren und installieren. Dieser Konnektor wird verwendet, um Daten aus einem Kinesis Stream zu konsumieren, der als Anwendungsquelle verwendet wird, oder um Daten in einen Kinesis Stream zu schreiben, der für die Anwendungsausgabe verwendet wird.

Anmerkung

Stellen Sie sicher, dass Sie den Konnektor mit KPL-Version 0.14.0 oder höher erstellen.

Gehen Sie wie folgt vor, um den Quellcode von Apache Flink Version 1.8.2 herunterzuladen und zu installieren:

  1. Stellen Sie sicher, dass Sie Apache Maven installiert haben und dass Ihre JAVA_HOME Umgebungsvariable auf ein JDK und nicht auf eine JRE verweist. Sie können Ihre Apache Maven-Installation mit dem folgenden Befehl testen:

    mvn -version

  2. Laden Sie den Quellcode von Apache Flink Version 1.8.2 herunter:

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

  3. Dekomprimieren Sie den Apache Flink-Quellcode:

    tar -xvf flink-1.8.2-src.tgz

  4. Wechseln Sie in das Apache Flink-Quellcodeverzeichnis:

    cd flink-1.8.2

  5. Kompilieren und installieren Sie Apache Flink:

    mvn clean install -Pinclude-kinesis -DskipTests
    Anmerkung

    Wenn Sie Flink unter Microsoft Windows kompilieren, müssen Sie den -Drat.skip=true Parameter hinzufügen.

Anwendungen mit Apache Flink 1.8.2 erstellen

Dieser Abschnitt enthält Informationen über Komponenten, die Sie für die Erstellung von Managed Service für Apache Flink-Anwendungen verwenden, die mit Apache Flink 1.8.2 funktionieren.

Verwenden Sie die folgenden Komponentenversionen für Managed Service für Apache Flink-Anwendungen:

Komponente Version
Java 1.8 (empfohlen)
Apache Flink 1.8.2
Managed Service für Apache Flink für Flink Laufzeit (aws-kinesisanalytics-runtime) 1.0.1
Managed Service für Apache Flink Flink-Konnektoren (aws-kinesisanalytics-runtime) 1.0.1
Apache Maven 3.1

Um eine Anwendung mit Apache Flink 1.8.2 zu kompilieren, führen Sie Maven mit dem folgenden Parameter aus:

mvn package -Dflink.version=1.8.2

Ein Beispiel für eine pom.xml-Datei für eine Managed Service für Apache Flink-Anwendung, die Apache Flink Version 1.8.2 verwendet, finden Sie in der Managed Service für Apache Flink 1.8.2 Erste Schritte-Anwendung.

Informationen zum Erstellen und Verwenden von Anwendungscode für eine Managed Service für Apache Flink-Anwendung finden Sie unter Erstellen von Anwendungen.

Erstellen von Anwendungen mit Apache Flink 1.6.2

Dieser Abschnitt enthält Informationen über Komponenten, die Sie für die Erstellung von Managed Service für Apache Flink-Anwendungen verwenden, die mit Apache Flink 1.6.2 funktionieren.

Verwenden Sie die folgenden Komponentenversionen für Managed Service für Apache Flink-Anwendungen:

Komponente Version
Java 1.8 (empfohlen)
AWS Java-SDK 1.11.379
Apache Flink 1.6.2
Managed Service für Apache Flink für Flink Laufzeit (aws-kinesisanalytics-runtime) 1.0.1
Managed Service für Apache Flink Flink-Konnektoren (aws-kinesisanalytics-runtime) 1.0.1
Apache Maven 3.1
Apache Beam Wird mit Apache Flink 1.6.2 nicht unterstützt.
Anmerkung

Wenn Sie Managed Service für Apache Flink Laufzeit Version 1.0.1 verwenden, geben Sie die Version von Apache Flink in Ihrer pom.xml-Datei an, anstatt den -Dflink.version-Parameter beim Kompilieren Ihres Anwendungscodes zu verwenden.

Ein Beispiel für eine pom.xml-Datei für eine Managed Service für Apache Flink-Anwendung, die Apache Flink Version 1.6.2 verwendet, finden Sie in der Managed Service für Apache Flink 1.6.2 Erste Schritte-Anwendung.

Informationen zum Erstellen und Verwenden von Anwendungscode für eine Managed Service für Apache Flink-Anwendung finden Sie unter Erstellen von Anwendungen.

Aktualisieren von Anwendungen

Um die Version einer Managed Service für Apache Flink-Anwendung zu aktualisieren, müssen Sie Ihren Anwendungscode aktualisieren, die vorherige Anwendung löschen und eine neue Anwendung mit dem aktualisierten Code erstellen. Gehen Sie dazu wie folgt vor:

  • Ändern Sie die Versionen von Managed Service für Apache Flink Laufzeit und Managed Service für Apache Flink Flink-Konnektoren (aws-kinesisanalytics-flink) in der pom.xml-Datei Ihrer Anwendung auf 1.1.0.

  • Entfernen Sie die flink.version-Eigenschaft aus der pom.xml-Datei Ihrer Anwendung. Sie geben diesen Parameter an, wenn Sie den Anwendungscode im nächsten Schritt kompilieren.

  • Kompilieren Sie Ihren Anwendungscode mit dem folgenden Befehl neu:

    mvn package -Dflink.version=1.15.3

  • Löschen Sie Ihre bestehende Anwendung. Erstellen Sie Ihre Anwendung erneut und wählen Sie Apache Flink Version 1.15.2 (empfohlene Version) für die Laufzeit der Anwendung.

Anmerkung

Sie können keine Snapshots aus Ihren früheren Anwendungsversionen verwenden.

Verfügbare Konnektoren in Apache Flink 1.6.2 und 1.8.2

Das Apache Flink Framework enthält Konnektoren für den Zugriff auf Daten aus verschiedenen Quellen.