Teilen über

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

  • Artikel

Hinweis

Azure HDInsight on AKS wird am 31. Januar 2025 eingestellt. Vor dem 31. Januar 2025 müssen Sie Ihre Workloads zu Microsoft Fabric oder einem gleichwertigen Azure-Produkt migrieren, um eine abruptes Beendigung Ihrer Workloads zu vermeiden. Die verbleibenden Cluster in Ihrem Abonnement werden beendet und vom Host entfernt.

Bis zum Einstellungsdatum ist nur grundlegende Unterstützung verfügbar.

Wichtig

Diese Funktion steht derzeit als Vorschau zur Verfügung. Die zusätzlichen Nutzungsbedingungen für Microsoft Azure-Vorschauen enthalten weitere rechtliche Bestimmungen, die für Azure-Features in Betaversionen, in Vorschauversionen oder anderen Versionen gelten, die noch nicht allgemein verfügbar gemacht wurden. Informationen zu dieser spezifischen Vorschau finden Sie unter Informationen zur Vorschau von Azure HDInsight on AKS. Bei Fragen oder Funktionsvorschlägen senden Sie eine Anfrage an AskHDInsight mit den entsprechenden Details, und folgen Sie uns für weitere Updates in der Azure HDInsight-Community.

Dieses Beispiel zeigt Ihnen, wie Sie den Apache Flink CLI-Client unter HDInsight auf AKS-Clustern über SSH auf dem Azure-Portal aufrufen. Wir gehen sowohl auf SQL als auch auf Flink DataStream ein.

Voraussetzungen

  • Sie müssen SSH während der Erstellung des Flink-Clusters auswählen.

Herstellen einer Verbindung zu SSH im Azure-Portal

Nachdem der Flink-Cluster erstellt wurde, können Sie im linken Bereich die Option Einstellungen für den Zugriff auf Secure Shell anzeigen.

Screenshot des Erstellen eines Pods und des Herstellens einer Verbindung mit WebSSH.

Herstellen einer Verbinden zum SQL-Client

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

Screenshot des Auffindens der SQL-Clientdatei.

Screenshot des Ausführens des SQL-Clients.

Sie befinden Sich nun im Flink SQL-Client.

Informationen zu weiteren Tests finden Sie in diesem Artikel.

Flink stellt die Befehlszeilenschnittstelle bin/flink (Command-Line Interface, CLI) bereit, mit der Programme ausgeführt werden können, die als JAR-Dateien gepackt sind, und mit der ihre Ausführung gesteuert werden kann.

Die CLI ist ein Teil von Secure Shell (SSH). Sie stellt eine Verbindung zur ausgeführten JobManager-Instanz her und verwendet die Clientkonfigurationen, die unter conf/flink-conf.yaml angegeben sind.

Beim Übermitteln eines Auftrags wird dessen JAR-Datei in den SSH-Pod hochgeladen und die Ausführung des Auftrags initiiert. Als Beispiel für diesen Artikel dient ein Auftrag mit langer Ausführungszeit wie examples/streaming/StateMachineExample.jar.

Hinweis

Bei der Verwaltung von Abhängigkeiten sollte eine FAT-JAR-Datei erstellt und übermittelt werden.

  • Laden Sie die FAT-JAR-Datei aus ABFS in WebSSH hoch.

  • Sie müssen die Clientkonfigurationen mithilfe der Flink-Konfigurationsverwaltung unter „flink-client-configs“ für Ihren Anwendungsfall bearbeiten.

  • Führen Sie „StateMachineExample.jar“ aus.

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

Hinweis

Wenn Sie den Auftrag mit dem Modus --detached übermitteln, gibt der Befehl nach Abschluss der Übermittlung eine Ausgabe zurück. Diese enthält die ID des neu übermittelten Auftrags.

Verweis