Az Apache Flink® CLI-ügyfél elérése a HDInsighton futó Secure Shell (SSH) használatával AKS-fürtökön az Azure Portallal

Fontos

Ez a szolgáltatás jelenleg előzetes kiadásban elérhető. A Microsoft Azure Előzetes verzió kiegészítő használati feltételei további jogi feltételeket tartalmaznak, amelyek a bétaverzióban, előzetes verzióban vagy egyébként még nem általánosan elérhető Azure-funkciókra vonatkoznak. Erről az adott előzetes verzióról az Azure HDInsight az AKS előzetes verziójában tájékozódhat. Ha kérdése vagy funkciójavaslata van, küldjön egy kérést az AskHDInsightban a részletekkel együtt, és kövessen minket további frissítésekért az Azure HDInsight-közösségről.

Ez a példa bemutatja, hogyan adhatja meg az Apache Flink CLI-ügyfelet a HDInsighton az AKS-fürtökön az Azure Portal SSH-jával, és az SQL-t és az Flink DataStreamet is lefedjük.

Előfeltételek

• Az Flink-fürt létrehozása során SSH-t kell választania

Csatlakozás az Azure Portalról az SSH-ba

Az Flink-fürt létrehozása után a bal oldali panelen megfigyelheti a Secure Shell elérésének Gépház lehetőségét

Apache Flink SQL

Csatlakozás sql-ügyfélhez

Módosítania kell a könyvtárat /opt/flink-webssh/bin , majd végre kell hajtania ./sql-client.sh

Most már az SQL-ügyfélen dolgozik az Flinken

Tekintse meg ezt a dokumentumot néhány további teszt végrehajtásához.

Apache Flink DataStream

Az Flink parancssori felületet (CLI) bin/flink biztosít a JAR-fájlként csomagolt programok futtatásához és azok végrehajtásának szabályozásához.

A CLI része a Secure Shellnek (SSH), és csatlakozik a futó JobManagerhez, és a megadott ügyfélkonfigurációkat használja.conf/flink-conf.yaml

A feladat elküldése azt jelenti, hogy feltölti a feladat JAR-ját az SSH-podra, és elindítja a feladat végrehajtását. A cikk egy példájának szemléltetéséhez kiválasztunk egy hosszú ideig futó feladatot, például examples/streaming/StateMachineExample.jar.

Feljegyzés

A függőségek kezelése érdekében az elvárás egy zsíros jar létrehozása és elküldése a feladathoz.

• Töltse fel a fat job jar-t az ABFS-ből a webssh-be.

• A használati eset alapján az ügyfélkonfigurációkat az Flink-konfigurációkezelés használatával kell szerkesztenie az flink-client-configs alatt.

• Futtassuk a StateMachineExample.jar

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

Feljegyzés

A feladat elküldése --detached a beküldés után visszaadja a parancsot. A kimenet az újonnan elküldött feladat azonosítóját tartalmazza.

Referencia

• Flink SQL-ügyfél
• Az Apache, az Apache Flink, a Flink és a társított nyílt forráskód projektnevek az Apache Software Foundation (ASF) védjegyei.