Dela via

Få åtkomst till Apache Flink® CLI-klienten med Secure Shell (SSH) i HDInsight i AKS-kluster med Azure-portalen

  • Artikel

Viktig

Azure HDInsight på AKS drogs tillbaka den 31 januari 2025. Läs mer i det här meddelandet .

Du måste migrera dina arbetsbelastningar till Microsoft Fabric- eller en motsvarande Azure-produkt för att undvika plötsliga uppsägningar av dina arbetsbelastningar.

Viktig

Den här funktionen är för närvarande i förhandsversion. De kompletterande användningsvillkoren för Förhandsversioner av Microsoft Azure innehåller ytterligare juridiska villkor som gäller för Azure-funktioner som är i betaversioner, förhandsversioner eller på annat sätt ännu inte tillgängliggjorts för allmänheten. Information om den här specifika förhandsversionen finns i Azure HDInsight på AKS-förhandsversionsinformation. För frågor eller funktionsförslag, vänligen skicka en begäran till AskHDInsight med detaljerna och följ oss för fler uppdateringar om Azure HDInsight Community.

Det här exemplet beskriver hur du anger Apache Flink CLI-klienten i HDInsight i AKS-kluster med hjälp av SSH på Azure-portalen. Vi tar upp både SQL och Flink DataStream.

Förutsättningar

Ansluta till SSH från Azure-portalen

När Flink-klustret har skapats kan du se alternativet Inställningar i det vänstra fönstret för att få åtkomst till Secure Shell-

Skärmbild som visar Hur du skapar POD och ansluter till webssh.

Ansluta till SQL-klienten

Du måste ändra katalogen till /opt/flink-webssh/bin och sedan köra ./sql-client.sh

Skärmbild som visar hur du hittar sql-klientfilen.

Skärmbild som visar hur du kör SQL-klienten.

Du är nu på SQL-klienten på Flink

Se dokumentet för att utföra några fler tester.

Flink tillhandahåller en Command-Line Interface (CLI) bin/flink för att köra program som paketeras som JAR-filer och för att styra deras körning.

CLI är en del av Secure Shell (SSH) och ansluter till den jobmanager som körs och använder de klientkonfigurationer som anges i conf/flink-conf.yaml.

Att skicka ett jobb innebär att ladda upp jobbets JAR till SSH-podden och initiera jobbkörningen. För att illustrera ett exempel för den här artikeln väljer vi ett tidskrävande jobb som examples/streaming/StateMachineExample.jar.

Not

För att hantera beroenden förväntas det att man skapar och skickar en stor JAR-fil för jobbet.

  • Ladda upp den stora jobbsamlingen från ABFS till WebSSH.

  • Baserat på ditt användningsfall måste du redigera klientkonfigurationerna med hjälp av Flink-konfigurationshantering under flink-client-configs.

  • Låt oss köra StateMachineExample.jar

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

Obs

Om du skickar jobbet med hjälp av --detached returneras kommandot när överföringen är klar. Utdata innehåller ID:t för det nyligen skickade jobbet.

Hänvisning