Wie stelle ich neue Änderungen meines Flow im Apache Flink-Cluster bereit?

Question

Zum Beispiel habe ich JAR mit meinem Fluss hochgeladen und es über Apache Flink Dashboard laufen. Dann habe ich einige Änderungen im Flow implementiert und möchte sie bereitstellen.

Kann mir jemand Schritt für Schritt erklären, wie ich eine neue Version meines Flow zum Apache Flink-Cluster korrekt bereitstellen kann (ohne Ausfallzeiten, Zustandsverlust usw.)? Ich habe die Beschreibung des Bereitstellungsprozesses in der offiziellen Dokumentation nicht gefunden.

Answer 1

Was Sie verwenden möchten, ist die savepoints in Flink.

Die Schritte sind wie folgt:

• Bereiten Sie die neue Glas für Ihren Job
• Speichern Sie den Zustand des aktuell laufenden Job flink savepoint <JobID>
• Stoppen Sie den Job
• Starten Sie das neue Glas mit mit die soeben erstellte Sicherungspunkt flink run -s <pathToSavepoint> <jobJar> ...

Siehe auch: http://data-artisans.com/how-apache-flink-enables-new-streaming-applications/