Přístup k klientovi Apache Flink® CLI pomocí Secure Shellu (SSH) ve službě HDInsight v clusterech AKS pomocí webu Azure Portal

Poznámka:

Azure HDInsight vyřadíme ze služby AKS 31. ledna 2025. Před 31. lednem 2025 budete muset migrovat úlohy do Microsoft Fabric nebo ekvivalentního produktu Azure, abyste se vyhnuli náhlému ukončení úloh. Zbývající clustery ve vašem předplatném se zastaví a odeberou z hostitele.

Do data vyřazení bude k dispozici pouze základní podpora.

Důležité

Tato funkce je aktuálně dostupná jako ukázková verze. Doplňkové podmínky použití pro Microsoft Azure Preview obsahují další právní podmínky, které se vztahují na funkce Azure, které jsou v beta verzi, ve verzi Preview nebo ještě nejsou vydány v obecné dostupnosti. Informace o této konkrétní verzi Preview najdete v tématu Azure HDInsight o službě AKS ve verzi Preview. Pokud máte dotazy nebo návrhy funkcí, odešlete prosím žádost na AskHDInsight s podrobnostmi a sledujte nás o dalších aktualizacích v komunitě Azure HDInsight.

V tomto příkladu se dozvíte, jak zadat klienta Apache Flink CLI ve službě HDInsight v clusterech AKS pomocí SSH na webu Azure Portal, probereme SQL i Flink DataStream.

Požadavky

• Při vytváření clusteru Flink musíte vybrat SSH.

Připojení k SSH z webu Azure Portal

Po vytvoření clusteru Flink můžete v levém podokně sledovat možnost Nastavení pro přístup ke službě Secure Shell.

Apache Flink SQL

Připojení ke klientovi SQL

Musíte změnit adresář na /opt/flink-webssh/bin a pak spustit. ./sql-client.sh

Teď jste na sql Clientu na Flinku

Další testy najdete v tomto dokumentu.

Apache Flink DataStream

Flink poskytuje rozhraní příkazového řádku (CLI) bin/flink ke spouštění programů, které jsou zabalené jako soubory JAR a k řízení jejich provádění.

Rozhraní příkazového řádku je součástí Secure Shellu (SSH) a připojuje se ke spuštěné JobManager a používá konfigurace klienta zadané na adrese conf/flink-conf.yaml.

Odeslání úlohy znamená nahrání souboru JAR úlohy do podu SSH a zahájení provádění úlohy. Pro ilustraci příkladu pro tento článek vybereme dlouho běžící úlohu, například examples/streaming/StateMachineExample.jar.

Poznámka:

Pro správu závislostí očekáváme, že se sestaví a odešle fat jar pro úlohu.

• Nahrajte soubor JAR úlohy fat z ABFS na webssh.

• V závislosti na vašem případu použití budete muset upravit konfigurace klienta pomocí správy konfigurace Flink v rámci flink-client-configs.

• Pojďme spustit StateMachineExample.jar

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

Poznámka:

Odesláním úlohy pomocí --detached příkazu se příkaz vrátí po odeslání. Výstup obsahuje ID nově odeslané úlohy.

Reference

• Flink SQL Client
• Názvy apache, Apache Flink, Flink a přidružených opensourcových projektů jsou ochranné známky Apache Software Foundation (ASF).