Aktivieren Sie System-Rollbacks für Ihre Managed Service for Apache Flink-Anwendung

Mit der System-Rollback-Funktion können Sie eine höhere Verfügbarkeit Ihrer laufenden Apache Flink-Anwendung auf Amazon Managed Service for Apache Flink erreichen. Wenn Sie sich für diese Konfiguration entscheiden, kann der Service die Anwendung automatisch auf die zuvor ausgeführte Version zurücksetzen, wenn eine Aktion wie Code UpdateApplication - oder autoscaling Konfigurationsfehler auftritt.

Anmerkung

Um die System-Rollback-Funktion nutzen zu können, müssen Sie sich anmelden, indem Sie Ihre Anwendung aktualisieren. Bestehende Anwendungen verwenden standardmäßig nicht automatisch das System-Rollback.

Funktionsweise

Wenn Sie einen Anwendungsvorgang starten, z. B. eine Aktualisierungs- oder Skalierungsaktion, versucht der Amazon Managed Service für Apache Flink zunächst, diesen Vorgang auszuführen. Wenn Probleme erkannt werden, die den Erfolg des Vorgangs verhindern, wie z. B. Codefehler oder unzureichende Berechtigungen, leitet der Service automatisch einen Vorgang ein. RollbackApplication

Beim Rollback wird versucht, die Anwendung auf die vorherige Version, die erfolgreich ausgeführt wurde, zusammen mit dem zugehörigen Anwendungsstatus wiederherzustellen. Wenn das Rollback erfolgreich ist, setzt Ihre Anwendung die Datenverarbeitung mit minimaler Ausfallzeit mit der vorherigen Version fort. Wenn das automatische Rollback ebenfalls fehlschlägt, versetzt Amazon Managed Service for Apache Flink die Anwendung in den READY Status, sodass Sie weitere Maßnahmen ergreifen können, einschließlich der Behebung des Fehlers und der Wiederholung des Vorgangs.

Sie müssen sich für automatische System-Rollbacks anmelden. Sie können es ab diesem Zeitpunkt über die Konsole oder API für alle Operationen in Ihrer Anwendung aktivieren.

Die folgende Beispielanforderung für die UpdateApplication Aktion ermöglicht System-Rollbacks für eine Anwendung:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 1,
   "ApplicationConfigurationUpdate": { 
      "ApplicationSystemRollbackConfigurationUpdate": { 
         "RollbackEnabledUpdate": "true"
       }
    }
}

Sehen Sie sich gängige Szenarien für automatisches System-Rollback an

Die folgenden Szenarien veranschaulichen, wo automatische System-Rollbacks von Vorteil sind:

• Anwendungsupdates: Wenn Sie Ihre Anwendung mit neuem Code aktualisieren, der Fehler aufweist, wenn Sie den Flink-Job über die Hauptmethode initialisieren, ermöglicht das automatische Rollback die Wiederherstellung der vorherigen Arbeitsversion. Zu den weiteren Aktualisierungsszenarien, in denen System-Rollbacks hilfreich sind, gehören:

  • Wenn Ihre Anwendung so aktualisiert wurde, dass sie mit einer höheren Parallelität als ausgeführt wird. maxParallelism

  • Wenn Ihre Anwendung so aktualisiert wird, dass sie mit falschen Subnetzen für eine VPC Anwendung läuft, führt dies zu einem Fehler beim Start des Flink-Jobs.

• Upgrades der Flink-Version: Wenn Sie auf eine neue Apache Flink-Version aktualisieren und bei der aktualisierten Anwendung ein Snapshot-Kompatibilitätsproblem auftritt, können Sie mit dem System-Rollback automatisch zur vorherigen Flink-Version zurückkehren.

• AutoScaling: Wenn die Anwendung hochskaliert, aber Probleme bei der Wiederherstellung von einem Savepoint auftreten, weil die Operatoren zwischen dem Snapshot und dem Flink-Job-Diagramm nicht übereinstimmen.

Verwenden Sie den Vorgang für System-Rollbacks APIs

Um für mehr Transparenz zu sorgen, bietet Amazon Managed Service für Apache Flink zwei Funktionen, die sich auf Anwendungsvorgänge APIs beziehen und Ihnen helfen können, Fehler und damit verbundene System-Rollbacks nachzuverfolgen.

ListApplicationOperations

Hier werden alle an der Anwendung ausgeführten Operationen, einschließlich, und anderer UpdateApplication MaintenanceRollbackApplication, in umgekehrter chronologischer Reihenfolge API aufgeführt. In der folgenden Beispielanforderung für die ListApplicationOperations Aktion werden die ersten 10 Anwendungsvorgänge für die Anwendung aufgeführt:

{
   "ApplicationName": "MyApplication",
   "Limit": 10
}

Die folgende Beispielanforderung für ListApplicationOperations hilft dabei, die Liste nach früheren Updates für die Anwendung zu filtern:

{
   "ApplicationName": "MyApplication",
   "operation": "UpdateApplication"
}

DescribeApplicationOperation

Dies API enthält detaillierte Informationen zu einem bestimmten Vorgang, die unter aufgeführt sindListApplicationOperations, einschließlich der Fehlerursache, falls zutreffend. In der folgenden Beispielanforderung für die DescribeApplicationOperation Aktion werden Details für einen bestimmten Anwendungsvorgang aufgeführt:

{
   "ApplicationName": "MyApplication",
   "OperationId": "xyzoperation"
}

Informationen zur Problembehebung finden Sie unter Bewährte Methoden für das Rollback von Systemen.