Přístup k klientovi Apache Flink® CLI pomocí Secure Shellu (SSH) ve službě HDInsight v clusterech AKS pomocí webu Azure Portal
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í na 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í pro klienta 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).
Váš názor
https://aka.ms/ContentUserFeedback.
Připravujeme: V průběhu roku 2024 budeme postupně vyřazovat problémy z GitHub coby mechanismus zpětné vazby pro obsah a nahrazovat ho novým systémem zpětné vazby. Další informace naleznete v tématu:Odeslat a zobrazit názory pro