Mein Flink-Job hat eine JAR-Datei, die vom Client zur Verfügung gestellt wird, die ich im Ordner/lib speichern kann. Gibt es eine Möglichkeit, die aktualisierte JAR-Datei neu zu laden, ohne den Cluster neu zu starten?Apache Flink: Wie kann ich ein aktualisiertes Glas neu laden, ohne meinen Job neu zu starten?
Nein, das ist mit der aktuellen Version nicht möglich (Flink 1.4.0, Dez 2017).
Flink bietet savepoints an, um den Status einer Anwendung zu speichern. Wenn Sie den Code (oder die Abhängigkeiten) einer Anwendung ändern möchten, müssen Sie einen Sicherungspunkt übernehmen, den Code/die Abhängigkeiten aktualisieren und die Anwendung vom Sicherungspunkt aus neu starten.
Diese Technik kann auch verwendet werden, um eine Anwendung nach oben oder unten zu skalieren oder zu migrieren.
Danke. Ist dies für zukünftige Versionen möglich? – wittyameta
Mir sind keine Bemühungen in dieser Richtung bekannt. Die Community arbeitet an viel schnelleren Sicherungspunkten und Wiederherstellungszyklen. Wenn ein Job vorübergehend angehalten wird (d. H. Es ist kein Fehler aufgetreten), können Daten lokal gespeichert und die Prozesse nur neu gestartet werden. –