Compartir vía

Acceso al cliente de la CLI de Apache Flink® mediante Secure Shell (SSH) en HDInsight en clústeres de AKS con Azure Portal

  • Artículo

Importante

Azure HDInsight en AKS se retiró el 31 de enero de 2025. Obtenga más información con este anuncio.

Debe migrar las cargas de trabajo a microsoft Fabric o un producto equivalente de Azure para evitar la terminación repentina de las cargas de trabajo.

Importante

Esta característica está actualmente en versión preliminar. Los Términos de uso complementarios para las versiones preliminares de Microsoft Azure incluyen más términos legales que se aplican a las características de Azure que se encuentran en versión beta, en versión preliminar o, de lo contrario, aún no se han publicado en disponibilidad general. Para obtener información sobre esta versión preliminar específica, consulte información sobre la versión preliminar de Azure HDInsight en AKS. Para preguntas o sugerencias de características, envíe una solicitud en AskHDInsight con los detalles y síganos para obtener más actualizaciones sobre Comunidad de Azure HDInsight.

Este ejemplo muestra cómo acceder al cliente de la CLI de Apache Flink en HDInsight en clústeres de AKS utilizando SSH en el portal de Azure, y cubrimos tanto SQL como Flink DataStream.

Prerrequisitos

  • Es necesario seleccionar SSH durante la creación de del clúster de Flink.

Conexión a SSH desde Azure Portal

Una vez creado el clúster de Flink, puede observar en el panel izquierdo la opción Ajustes para acceder a la Shell Segura .

Captura de pantalla que muestra cómo crear POD y conectarse a webssh.

Conexión al cliente SQL

Es necesario cambiar el directorio a /opt/flink-webssh/bin y, a continuación, ejecutar ./sql-client.sh

Captura de pantalla sobre cómo buscar el archivo de cliente sql.

Captura de pantalla que muestra cómo ejecutar el cliente SQL.

Ahora está en SQL Client en Flink

Consulte este documento para realizar algunas pruebas más.

Flink proporciona una interfaz de Command-Line (CLI) bin/flink para ejecutar programas que se empaquetan como archivos JAR y para controlar su ejecución.

La CLI forma parte de Secure Shell (SSH) y se conecta al JobManager en ejecución y usa las configuraciones de cliente especificadas en conf/flink-conf.yaml.

Enviar un trabajo significa cargar el archivo JAR del trabajo en el pod SSH e iniciar la ejecución del trabajo. Para ilustrar un ejemplo de este artículo, seleccionamos un trabajo de ejecución prolongada como examples/streaming/StateMachineExample.jar.

Nota

Para gestionar las dependencias, se espera compilar y enviar un fat jar para el trabajo.

  • Suba el archivo JAR completo desde ABFS a webssh.

  • En función del caso de uso, es necesario editar las configuraciones de cliente mediante administración de configuración de Flink en flink-client-configs.

  • Vamos a ejecutar StateMachineExample.jar

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

Nota

Enviar el trabajo mediante --detached hará que el comando se devuelva después de completar el envío. La salida contiene el identificador del trabajo recién enviado.

Referencia