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

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.

Apache Flink SQL

Herstellen einer Verbinden zum SQL-Client

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

Sie befinden Sich nun im Flink SQL-Client.

Informationen zu weiteren Tests finden Sie in diesem Artikel.

Apache Flink DataStream

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

• Flink SQL-Client
• Apache, Apache Flink, Flink und zugehörige Open-Source-Projektnamen sind Marken der Apache Software Foundation (ASF).