Die Rule Engine aktualisieren

Als Flink-Administrator führt Sie dieser Abschnitt durch den Upgrade-Prozess der Rule Engine.

Diese Seite beinhaltet Folgendes:

Upgrade-Prozess für v12.2.0 und höher

Die folgenden Schritte werden bei der Migration von einer alten Version von Apache Flink auf eine neue Version empfohlen. Dieser Upgrade-Prozess ermöglicht es, den Status der Regeln zu erhalten.

Hinweise:

  • Der Begriff alt bezieht sich auf Ihre aktuelle Installation des Apache Flink-Clusters, der vom IA-Agenten verwendet wird. Der Begriff neu bezieht sich auf den Ziel-Apache-Flink-Cluster.

  • Unter Windows verwenden Sie flink.bat

Wichtig! Dieses Update gilt nur, wenn eine zustandsbehaftete Regel (d. h. die State Change Rule) auf einem bestehenden Apache Flink-Cluster läuft.

Die Rule Engine aktualisieren (Apache Flink)

  1. Stoppen Sie den IA-Agenten
  2. Verbinden Sie sich mit dem alten Apache Flink Job Manager-Computer und navigieren Sie zum Apache Flink bin-Verzeichnis
  3. Identifizieren Sie mithilfe der Kommandozeilenschnittstelle laufende Jobs, die Sie migrieren möchten, indem Sie einen der beiden Befehle eingeben:

    ./flink list - Liste der geplanten und laufenden Jobs (einschließlich ihrer Job-IDs)
    ./flink list -r - Liste laufender Jobs (einschließlich ihrer JobIDs)

  4. Extrahieren Sie die Ausführungs-IDs aller ausgeführten Jobs aus dem Job-Namen, um die Datei savepoint.properties zu erstellen.
    Die Ausführungs-ID kann aus der Liste der Flink-Jobs extrahiert werden, deren Namen dem Muster folgen:

    <Namensbereich>|<Agentenname>|<Mandant>|<Ausführungs-ID>

  5. Brechen Sie jeden Job im alten Cluster ab und erstellen Sie entsprechende Snapshots.
    Siehe: Sicherungspunkte auslösen.

    Um die Sicherungspunkte später einfach wiederherzustellen, wird empfohlen, sie in einem Unterverzeichnis mit dem Namen der Apache Flink Job-ID anzulegen:

    ./flink cancel -s /tmp/<flink_job_id> <flink_job_id>

  6. Kopieren der Sicherungspunkt-Ordner auf den neuen Cluster
  7. Erstellen Sie eine Datei savepoints.properties mit dem folgenden Inhalt:

    <run-id>=<savepoint-path>

    Der Pfad zu dem Sicherungspunkt entspricht dem entsprechenden Sicherungspunkt-Jobpfad, z. B. /tmp/bcacb28fcb99d71e1c0d9641b28921f6/savepoint-bcacb2-6503a8eac076, im neuen Cluster.

  8. Aktualisieren Sie das Regelpaket auf eine Version, die den neuen Cluster unterstützt
  9. Konfigurieren Sie den IA-Agenten neu, um den neuen Cluster zu verwenden
  10. Kopieren Sie die Datei savepoints.properties in das Arbeitsverzeichnis des IA-Agenten
  11. Starten Sie den IA-Agenten
  12. Vergewissern Sie sich, dass alle Jobs wieder aufgenommen wurden, und löschen Sie dann die Datei „savepoint.properties“

Upgrade-Prozess für v12.1.0 und höher

Wichtig! Das Beibehalten des Regelstatus von einer Version von Flink zur nächsten wird in v12.1 nicht unterstützt.

Statusloses Upgrade mit ONE Installer

  1. Stoppen Sie den IA-Agenten
  2. Stoppen Sie die Rule Engine im Service Manager
  3. Aktualisieren Sie alle Regelpakete auf die Version, die die neue Version der Rule Engine unterstützt
  4. Rekonfigurieren Sie den Service Manager für die neue Rule Engine, indem Sie den Startpfad und das Arbeitsverzeichnis ändern
  5. Starten Sie die Rule Engine im Service Manager
  6. Starten Sie den IA-Agenten
  7. Die Regeln werden auf dem neuen Flink-Cluster neu gestartet

Statusloses Upgrade mit externem Cluster

  1. Stoppen Sie den IA-Agenten
  2. Aktualisieren Sie alle Regelpakete auf die Version, die die neue Version der Rule Engine unterstützt
  3. Rekonfigurieren Sie flink.host und flink.web_port des IA-Agenten, um auf einen neuen Flink-Cluster zu verweisen.
  4. Starten Sie den IA-Agenten
  5. Die Regeln werden auf dem neuen Flink-Cluster neu gestartet
  6. Brechen Sie jeden Job im alten Cluster ab und erstellen Sie entsprechende Snapshots.
    Siehe: Sicherungspunkte auslösen.