Dela via

Få åtkomst till Apache Flink® CLI-klienten med secure shell (SSH) på HDInsight i AKS-kluster med Azure Portal

  • Artikel

Kommentar

Vi drar tillbaka Azure HDInsight på AKS den 31 januari 2025. Före den 31 januari 2025 måste du migrera dina arbetsbelastningar till Microsoft Fabric eller en motsvarande Azure-produkt för att undvika plötsliga uppsägningar av dina arbetsbelastningar. Återstående kluster i din prenumeration stoppas och tas bort från värden.

Endast grundläggande stöd kommer att vara tillgängligt fram till datumet för pensionering.

Viktigt!

Den här funktionen finns i förhandsgranskning. De kompletterande användningsvillkoren för Förhandsversioner av Microsoft Azure innehåller fler juridiska villkor som gäller för Azure-funktioner som är i betaversion, förhandsversion eller på annat sätt ännu inte har släppts i allmän tillgänglighet. Information om den här specifika förhandsversionen finns i Azure HDInsight på AKS-förhandsversionsinformation. Om du vill ha frågor eller funktionsförslag skickar du en begäran på AskHDInsight med informationen och följer oss för fler uppdateringar i Azure HDInsight Community.

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

Förutsättningar

  • Du måste välja SSH när du skapar Flink-kluster

Ansluta till SSH från Azure Portal

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 katalog 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

Läs det här dokumentet om du vill utföra några fler tester.

Flink tillhandahåller ett kommandoradsgränssnitt (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.

Kommentar

För att hantera beroenden är förväntningarna att skapa och skicka en fet jar för jobbet.

  • Ladda upp den feta jobbburken 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

Kommentar

Om du skickar jobbet med kommer --detached kommandot att returneras när sändningen är klar. Utdata innehåller ID:t för det nyligen skickade jobbet.

Referens

  • Flink SQL-klient
  • Apache, Apache Flink, Flink och associerade öppen källkod projektnamn är varumärken som tillhör Apache Software Foundation (ASF).