Accedere al client dell'interfaccia della riga di comando apache Flink® usando Secure Shell (SSH) in HDInsight nei cluster del servizio Azure Kubernetes con portale di Azure

Importante

Questa funzionalità è attualmente disponibile solo in anteprima. Le condizioni per l'utilizzo supplementari per le anteprime di Microsoft Azure includono termini legali più validi applicabili alle funzionalità di Azure disponibili in versione beta, in anteprima o non ancora rilasciate nella disponibilità generale. Per informazioni su questa anteprima specifica, vedere Informazioni sull'anteprima di Azure HDInsight nel servizio Azure Kubernetes. Per domande o suggerimenti sulle funzionalità, inviare una richiesta in AskHDInsight con i dettagli e seguire microsoft per altri aggiornamenti nella community di Azure HDInsight.

Questo esempio illustra come immettere il client dell'interfaccia della riga di comando apache Flink in cluster HDInsight nei cluster del servizio Azure Kubernetes usando SSH in portale di Azure, vengono illustrati sia SQL che Flink DataStream.

Prerequisiti

• È necessario selezionare SSH durante la creazione del cluster Flink

Connessione tramite SSH da portale di Azure

Dopo aver creato il cluster Flink, è possibile osservare nel riquadro sinistro l'opzione Impostazioni per accedere a Secure Shell

Apache Flink SQL

Connessione ing in SQL Client

È necessario modificare la directory in /opt/flink-webssh/bin e quindi eseguire ./sql-client.sh

Si è ora in SQL Client in Flink

Fare riferimento a questo documento per eseguire altri test.

Apache Flink DataStream

Flink fornisce un'interfaccia della riga di comando (CLI) bin/flink per eseguire programmi inseriti come file JAR e per controllarne l'esecuzione.

L'interfaccia della riga di comando fa parte di Secure Shell (SSH) e si connette all'oggetto JobManager in esecuzione e usa le configurazioni client specificate in conf/flink-conf.yaml.

L'invio di un processo significa caricare il file JAR del processo nel pod SSH e avviare l'esecuzione del processo. Per illustrare un esempio di questo articolo, si seleziona un processo a esecuzione prolungata, ad examples/streaming/StateMachineExample.jaresempio .

Nota

Per la gestione delle dipendenze, si prevede di compilare e inviare un file jar fat per il processo.

• Caricare il file JAR del processo fat da ABFS a webssh.

• In base al caso d'uso, è necessario modificare le configurazioni client usando la gestione della configurazione Flink in flink-client-configs.

• Eseguiamo StateMachineExample.jar

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

Nota

L'invio del processo tramite --detached restituirà il comando al termine dell'invio. L'output contiene l'ID del processo appena inviato.

Riferimento

• Flink SQL Client
• Apache, Apache Flink, Flink e i nomi dei progetti open source associati sono marchi di Apache Software Foundation (ASF).