Wartung von Flink-Anwendungen - Amazon EMR
Upgrade-Modi

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.

Wartung von Flink-Anwendungen

Flink-Anwendungen sind in der Regel so konzipiert, dass sie über lange Zeiträume wie Wochen, Monate oder sogar Jahre ausgeführt werden können. Wie alle Services mit langer Laufzeit müssen auch Flink-Streaming-Anwendungen gewartet werden. Dies beinhaltet Fehlerbehebungen, Verbesserungen und die Migration zu einem Flink-Cluster einer späteren Version.

Wenn sich die Spezifikation für FlinkDeployment- und FlinkSessionJob-Ressourcen ändert, müssen Sie die laufende Anwendung aktualisieren. Zu diesem Zweck stoppt der Operator den laufenden Auftrag (sofern er nicht bereits unterbrochen wurde) und stellt ihn erneut mit der neuesten Spezifikation und, bei statusbehafteten Anwendungen, mit dem Status der vorherigen Ausführung bereit.

Benutzer steuern mit der upgradeMode-Einstellung von JobSpec, wie der Status verwaltet werden soll, wenn statusbehaftete Anwendungen beendet und wiederhergestellt werden.

Optionale Einführung

Zustandslos

Zustandslose Anwendungen werden aus dem Status „Leer“ aktualisiert.

Letzter Status

Schnelle Upgrades in jedem Anwendungsstatus (auch bei fehlgeschlagenen Aufträgen) erfordern keinen fehlerfreien Auftrag, da immer der letzte erfolgreiche Prüfpunkt verwendet wird. Eine manuelle Wiederherstellung kann erforderlich sein, wenn HA-Metadaten verloren gehen. Um die Zeit zu begrenzen, in der der Auftrag möglicherweise auf den letzten Prüfpunkt zurückgreifen kann, können Sie kubernetes.operator.job.upgrade.last-state.max.allowed.checkpoint.age konfigurieren. Wenn der Prüfpunkt älter als der konfigurierte Wert ist, wird stattdessen ein Savepoint für fehlerfreie Aufträge verwendet. Dies wird im Sitzungsmodus nicht unterstützt.

Savepoint

Verwenden Sie Savepoint für das Upgrade, der maximale Sicherheit und die Möglichkeit bietet, als Backup-/Fork-Point zu dienen. Der Savepoint wird während des Upgrade-Prozesses erstellt. Beachten Sie, dass der Flink-Auftrag ausgeführt werden muss, damit der Savepoint erstellt werden kann. Wenn sich der Job in einem fehlerhaften Zustand befindet, wird der letzte Checkpoint verwendet (es sei denn, kubernetes.operator.job.upgrade). last-state-fallback.enabled ist auf false gesetzt). Wenn der letzte Prüfpunkt nicht verfügbar ist, schlägt das Upgrade des Auftrags fehl.