Compartilhar via

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

  • Artigo

Importante

O Azure HDInsight no AKS se aposentou em 31 de janeiro de 2025. Saiba mais com este comunicado.

Você precisa migrar suas cargas de trabalho para microsoft fabric ou um produto equivalente do Azure para evitar o encerramento abrupto de suas cargas de trabalho.

Importante

Esse recurso está atualmente em versão prévia. Os termos de uso complementares para o Microsoft Azure Previews incluem mais termos legais que se aplicam aos recursos do Azure que estão em versão beta, em versão prévia ou ainda não lançados em disponibilidade geral. Para obter informações sobre essa versão prévia específica, consulte Azure HDInsight em informações de visualização do AKS. Para 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 orienta como inserir o cliente da CLI do Apache Flink no HDInsight em clusters AKS usando SSH no portal do Azure, abrangemos o SQL e o Flink DataStream.

Pré-requisitos

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

Conectando-se ao SSH no portal do Azure

Depois que o cluster Flink for criado, você poderá observar no painel esquerdo a opção Configurações para acessar Secure Shell

Captura de tela mostrando como criar o POD e conectar-se ao webssh.

Conectando-se ao CLIENTE SQL

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

Captura de tela de como localizar o arquivo cliente sql.

Captura de tela mostrando como executar o cliente SQL.

Agora você está no SQL Client no Flink

Consulte este documento para executar mais alguns testes.

O Flink fornece uma CLI (Interface Command-Line) bin/flink para executar programas que são empacotados como arquivos JAR e controlar sua execução.

A CLI é parte Secure Shell (SSH) 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 para o pod SSH e iniciar a execução do trabalho. Para dar um exemplo neste artigo, selecionamos uma tarefa de longa duração como examples/streaming/StateMachineExample.jar.

Nota

Para gerenciar dependências, a expectativa é criar e enviar um jar completo para a tarefa.

  • Carregue o arquivo jar executável do ABFS para o webssh.

  • Com base no seu caso de uso, você precisa editar as configurações do cliente utilizando o gerenciamento de configuração do Flink por meio de e em flink-client-configs.

  • Vamos executar StateMachineExample.jar

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

Nota

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