Condividi tramite

Accedere al client della riga di comando Apache Flink® utilizzando Secure Shell (SSH) in HDInsight sui cluster AKS su Azure con il portale di Azure

  • Articolo

Importante

Azure HDInsight su AKS è stato ritirato il 31 gennaio 2025. Scopri di più con questo annuncio.

È necessario eseguire la migrazione dei carichi di lavoro a Microsoft Fabric o a un prodotto Azure equivalente per evitare la chiusura brusca dei carichi di lavoro.

Importante

Questa funzionalità è attualmente in anteprima. Le condizioni supplementari per l'utilizzo per le anteprime di Microsoft Azure includono termini legali più validi applicabili alle funzionalità di Azure in versione beta, in anteprima o altrimenti non ancora rilasciate nella disponibilità generale. Per informazioni su questa anteprima specifica, vedere informazioni sull'anteprima di Azure HDInsight su AKS. Per domande o suggerimenti sulle funzionalità, inviare una richiesta su AskHDInsight con i dettagli e seguirci per ulteriori aggiornamenti su Community di Azure HDInsight.

Questo esempio illustra come accedere al client dell'interfaccia a riga di comando di Apache Flink nei cluster HDInsight sui cluster AKS utilizzando SSH nel portale di Azure; tratteremo 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 come trovare il file client SQL.

Screenshot che mostra come eseguire il client SQL.

Ora sei su SQL Client di Flink

Fare riferimento a questo documento per eseguire altri test.

Flink fornisce un'interfaccia Command-Line (CLI) bin/flink per eseguire programmi confezionati come file JAR e per controllarne l'esecuzione.

L'interfaccia della riga di comando fa parte di Secure Shell (SSH) e si connette al 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 per questo articolo, selezioniamo 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.

  • Carica il file JAR del job 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.

  • Facciamo girare 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