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

Článek
09/20/2024

Důležitý

Azure HDInsight na AKS byl ukončen 31. ledna 2025. Další informace s tímto oznámením .

Abyste se vyhnuli náhlému ukončení úloh, musíte migrovat úlohy do Microsoft Fabric nebo ekvivalentního produktu Azure.

Důležitý

Tato funkce je aktuálně ve verzi Preview. doplňkové podmínky použití pro verze Preview Microsoft Azure obsahují další právní podmínky, které se vztahují na funkce Azure, které jsou v beta verzi, ve verzi Preview nebo ještě nebyly vydány v obecné dostupnosti. Informace o této konkrétní verzi Preview najdete v Azure HDInsight na AKS Preview. Pokud máte dotazy nebo návrhy funkcí, odešlete prosím žádost o AskHDInsight s podrobnostmi a sledujte nás o dalších aktualizacích komunity 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 k Secure Shellu

Apache Flink SQL

Připojení ke klientovi SQL

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

Snímek obrazovky s vyhledáním souboru klienta SQL

snímek obrazovky ukazující, jak spustit klienta SQL

Teď jste na sql Clientu na Flinku

Podívejte se do tohoto dokumentu k provedení několika dalších testů.

Apache Flink DataStream

Flink poskytuje Command-Line Interface (CLI) bin/flink ke spouštění programů zabalených jako soubory JAR a k řízení jejich spuštění.

Rozhraní příkazového řádku je součástí protokolu Secure Shell (SSH), připojuje se ke spuštěnému JobManageru a používá konfigurace klienta zadané v 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, jako je examples/streaming/StateMachineExample.jar.

Poznámka

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

Nahrajte soubor JAR úlohy fat z ABFS na webssh.
V závislosti na vašem případu použití je potřeba upravit konfigurace klienta prostřednictvím správy konfigurace Flink pod flink-client-configs.

Pojďme spustit StateMachineExample.jar

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

Poznámka

Odeslání úlohy pomocí --detached způsobí, že se příkaz vrátí až po dokončení odeslání. Výstup obsahuje ID nově odeslané úlohy.

Odkaz

Flink SQL klient
Názvy projektů Apache, Apache Flink, Flink a souvisejících open-sourceových projektů jsou ochranné známky Apache Software Foundation (ASF).

Sdílet prostřednictvím