Freigeben über

Zugreifen auf den Apache Flink® CLI-Client mit Secure Shell (SSH) auf HDInsight auf AKS-Clustern mit Azure-Portal

  • Artikel

Wichtig

Azure HDInsight auf AKS wurde am 31. Januar 2025 eingestellt. Erfahren Sie mehr über in dieser Ankündigung.

Sie müssen Ihre Workloads zu Microsoft Fabric oder ein gleichwertiges Azure-Produkt migrieren, um eine abrupte Beendigung Ihrer Workloads zu vermeiden.

Wichtig

Dieses Feature befindet sich derzeit in der Vorschau. Die zusätzlichen Nutzungsbedingungen für Microsoft Azure Previews weitere rechtliche Bestimmungen enthalten, die für Azure-Features gelten, die in der Betaversion, in der Vorschau oder auf andere Weise noch nicht in die allgemeine Verfügbarkeit veröffentlicht werden. Informationen zu dieser spezifischen Vorschau finden Sie unter Azure HDInsight auf AKS-Vorschauinformationen. Für Fragen oder Funktionsvorschläge senden Sie bitte eine Anfrage an AskHDInsight mit den Details und folgen Sie uns für weitere Updates zur Azure HDInsight Community.

In diesem Beispiel wird beschrieben, wie Sie den Apache Flink CLI-Client auf HDInsight auf AKS-Clustern mithilfe von SSH im Azure-Portal eingeben. Wir behandeln sowohl SQL als auch Flink DataStream.

Voraussetzungen

  • Sie müssen SSH während Erstellung Flink Cluster auswählen.

Herstellen einer Verbindung mit dem SSH über das Azure-Portal

Nachdem der Flink-Cluster erstellt wurde, können Sie die Option Einstellungen nutzen, um auf Secure Shell zuzugreifen.

Screenshot, der zeigt, wie man POD erstellt und eine Verbindung mit webssh herstellt.

Herstellen einer Verbindung mit SQL-Client

Sie müssen in das Verzeichnis /opt/flink-webssh/bin wechseln und dann ./sql-client.sh ausführen.

Screenshot, wie Sie die SQL-Clientdatei finden.

Screenshot mit der Ausführung des SQL-Clients.

Sie befinden sich jetzt auf dem SQL-Client auf Flink

Lesen Sie dieses Dokument, um einige weitere Tests durchzuführen.

Flink stellt eine Command-Line Interface (CLI)-bin/flink bereit, um Programme auszuführen, die als JAR-Dateien verpackt sind und um die Ausführung zu steuern.

Die CLI ist Teil der Secure Shell (SSH) und stellt eine Verbindung zum ausgeführten JobManager her und verwendet die Clientkonfigurationen, die bei conf/flink-conf.yamlangegeben sind.

Das Übermitteln eines Auftrags bedeutet, den JAR des Auftrags auf den SSH-Pod hochzuladen und die Auftragsausführung zu initiieren. Um ein Beispiel für diesen Artikel zu veranschaulichen, wählen wir einen langfristigen Auftrag wie examples/streaming/StateMachineExample.jaraus.

Anmerkung

Für die Verwaltung von Abhängigkeiten besteht die Erwartung, dass ein fat jar für die Aufgabe erstellt und übermittelt wird.

  • Laden Sie das Fat Job Jar von ABFS nach WebSSH hoch.

  • Basierend auf Ihrem Anwendungsfall müssen Sie die Clientkonfigurationen mithilfe Flink-Konfigurationsverwaltung unter flink-client-configs bearbeiten.

  • Lassen Sie uns StateMachineExample.jar ausführen

    ./bin/flink run \
    --detached \
    ./examples/streaming/StateMachineExample.jar

Anmerkung

Wenn Sie den Auftrag mit --detached übermitteln, wird der Befehl nach Abschluss der Übermittlung zurückgegeben. Die Ausgabe enthält die ID des neu übermittelten Auftrags.

Referenz