Partilhar via

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

  • Artigo

Importante

O Azure HDInsight no AKS foi desativado em 31 de janeiro de 2025. Saiba mais com este anúncio.

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

Esta funcionalidade está atualmente em pré-visualização. Os Termos de Utilização Suplementares para Pré-visualizações do Microsoft Azure incluem mais termos jurídicos que se aplicam a funcionalidades do Azure em beta, em pré-visualização, ou ainda não disponíveis ao público. Para obter informações sobre essa visualização específica, consulte Azure HDInsight no AKS informações de visualização. Para perguntas ou sugestões para funcionalidades, envie uma solicitação no AskHDInsight com os detalhes e siga-nos para obter mais atualizações na Comunidade do Azure HDInsight .

Este exemplo orienta como inserir o cliente Apache Flink CLI no HDInsight em clusters AKS usando SSH no portal do Azure, abordamos SQL e Flink DataStream.

Pré-requisitos

  • É necessário selecionar SSH durante de criação do Flink Cluster

Conectando-se ao SSH a partir do portal do Azure

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

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

Conectando-se ao cliente SQL

É necessário alterar o diretório para /opt/flink-webssh/bin e, em seguida, executar ./sql-client.sh

Captura de tela como encontrar o arquivo do cliente sql.

Captura de tela mostrando como executar o cliente SQL.

Agora você está no SQL Client no Flink

Consulte este documento para realizar mais alguns testes.

Flink fornece uma interface Command-Line (CLI) bin/flink para executar programas embalados como arquivos JAR e controlar a sua execução.

A CLI faz parte do 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 ilustrar um exemplo para este artigo, selecionamos um trabalho de longa duração como examples/streaming/StateMachineExample.jar.

Observação

Para gerenciar dependências, a expectativa é construir e enviar um pote gordo para o trabalho.

  • Transfira o ficheiro "fat jar" do ABFS para o WebSSH.

  • Com base no seu caso de uso, é necessário editar as configurações do cliente usando de gerenciamento de configuração 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