Condividi tramite

Accedere al client dell'interfaccia della riga di comando di Apache Flink® usando Secure Shell (SSH) su HDInsight su AKS con il portale di Azure

  • Articolo

Nota

Azure HDInsight su AKS verrà ritirato il 31 gennaio 2025. Prima del 31 gennaio 2025, sarà necessario eseguire la migrazione dei carichi di lavoro a Microsoft Fabric o a un prodotto Azure equivalente per evitare interruzioni improvvise dei carichi di lavoro. I cluster rimanenti nella sottoscrizione verranno arrestati e rimossi dall’host.

Solo il supporto di base sarà disponibile fino alla data di ritiro.

Importante

Questa funzionalità è attualmente disponibile solo in anteprima. Le Condizioni per l'utilizzo supplementari per le anteprime di Microsoft Azure includono termini legali aggiuntivi che si applicano a funzionalità di Azure in versione beta, in anteprima o in altro modo non ancora disponibili a livello 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 di Apache Flink nei cluster HDInsight su AKS usando SSH nel portale di Azure e viene illustrato sia SQL che Flink DataStream.

Prerequisiti

  • È necessario selezionare SSH durante la creazione del cluster Flink

Connessione a SSH dal portale di Azure

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

Screenshot che mostra come creare pod e connettersi a Webssh.

Connessione a SQL Client

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

Screenshot di come trovare il file client SQL.

Screenshot che mostra come eseguire SQL client.

Si è ora in SQL Client in Flink

Fare riferimento a questo documento per eseguire alcuni altri test.

Flink fornisce un'interfaccia della riga di comando bin/flink per eseguire programmi inclusi in pacchetti 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.

Inviare 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 esempio examples/streaming/StateMachineExample.jar.

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 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