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.jar
esempio .
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).
Commenti e suggerimenti
https://aka.ms/ContentUserFeedback.
Presto disponibile: Nel corso del 2024 verranno gradualmente disattivati i problemi di GitHub come meccanismo di feedback per il contenuto e ciò verrà sostituito con un nuovo sistema di feedback. Per altre informazioni, vedereInvia e visualizza il feedback per