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