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

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

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

Anslut till SSH från Azure-portalen

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

Apache Flink SQL

Anslut till SQL-klienten

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

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

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

Apache Flink DataStream

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ärkensom tillhör Apache Software Foundation (ASF).