Acessar o cliente da CLI do Apache Flink® CLI usando o Secure Shell (SSH) no Azure HDInsight em clusters do AKS com o portal do Azure

Importante

Esse recurso está atualmente na visualização. Os Termos de Uso Complementares para Versões Prévias da Microsoft Azure incluem termos legais adicionais que se aplicam aos recursos do Azure que estão em versão beta, em versão de teste ou ainda não lançados para disponibilidade geral. Para informações sobre essa visualização específica, consulte o artigo Versão prévia do HDInsight no AKS. Para obter perguntas ou sugestões de recursos, envie uma solicitação no AskHDInsight com os detalhes e siga-nos para obter mais atualizações sobre a Comunidade do Azure HDInsight

Este exemplo guia como inserir o cliente da CLI do Apache Flink no Azure HDInsight em clusters do AKS usando SSH no portal do Microsoft Azure. Abordamos o SQL e o Flink DataStream

Pré-requisitos

  • Você precisa selecionar SSH durante a criação do Cluster Flink

Conectar-se ao SSH no portal do Azure

Após a criação do cluster Flink, você poderá observar no painel esquerdo a opção Configurações para acessar Secure Shell

Screenshot showing How to create POD and connect to webssh.

Conectar-se ao SQL Client

Você precisa alterar o diretório para /opt/flink-webssh/bin e, em seguida, executar ./sql-client.sh

Screenshot how to find sql client file.

Screenshot showing how to run SQL client.

Agora você está no SQL Client no Flink

Consulte este documento para executar mais alguns testes.

O Flink fornece uma CLI (interface de linha de comando) bin/flink para executar programas que são empacotados como arquivos JAR e para controlar a execução deles.

A CLI faz parte do SSH (Secure Shell) e se conecta ao JobManager em execução e usa as configurações de cliente especificadas em conf/flink-conf.yaml.

Enviar um trabalho significa carregar o JAR do trabalho no pod SSH e iniciar a execução do trabalho. Para ilustrar um exemplo deste artigo, selecionamos um trabalho de longa execução como examples/streaming/StateMachineExample.jar.

Observação

Para gerenciar dependências, a expectativa é criar e enviar um fat jar para o trabalho.

  • Carregue o fat jar de trabalho do ABFS para webssh.

  • Com base no caso de uso, você precisará editar as configurações do cliente usando o gerenciamento de configuração do Flink em flink-client-configs.

  • Vamos executar StateMachineExample.jar

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

Observação

O envio do trabalho usando --detached fará com que o comando retorne após a conclusão do envio. A saída contém a ID do trabalho recém-enviado.

Referência