Uzyskiwanie dostępu do klienta interfejsu wiersza polecenia platformy Apache Flink® przy użyciu protokołu Secure Shell (SSH) w usłudze HDInsight w klastrach usługi AKS za pomocą witryny Azure Portal

  • Artykuł

Ważne

Ta funkcja jest aktualnie dostępna jako funkcja podglądu. Dodatkowe warunki użytkowania dla wersji zapoznawczych platformy Microsoft Azure obejmują więcej warunków prawnych, które dotyczą funkcji platformy Azure, które znajdują się w wersji beta, w wersji zapoznawczej lub w inny sposób nie zostały jeszcze wydane w wersji ogólnodostępnej. Aby uzyskać informacje o tej konkretnej wersji zapoznawczej, zobacz Informacje o wersji zapoznawczej usługi Azure HDInsight w usłudze AKS. W przypadku pytań lub sugestii dotyczących funkcji prześlij żądanie w usłudze AskHDInsight , aby uzyskać szczegółowe informacje i postępuj zgodnie z nami, aby uzyskać więcej aktualizacji w społeczności usługi Azure HDInsight.

W tym przykładzie przedstawiono sposób wprowadzania klienta interfejsu wiersza polecenia platformy Apache Flink w usłudze HDInsight w klastrach usługi AKS przy użyciu protokołu SSH w witrynie Azure Portal. Omówiono zarówno język SQL, jak i Flink DataStream.

Wymagania wstępne

  • Musisz wybrać protokół SSH podczas tworzenia klastra Flink

Połączenie do protokołu SSH z witryny Azure Portal

Po utworzeniu klastra Flink możesz obserwować w okienku po lewej stronie opcję Ustawienia, aby uzyskać dostęp do protokołu Secure Shell

Zrzut ekranu przedstawiający sposób tworzenia zasobnika i nawiązywania połączenia z protokołem webssh.

Połączenie do klienta SQL

Musisz zmienić katalog na /opt/flink-webssh/bin , a następnie wykonać polecenie ./sql-client.sh

Zrzut ekranu przedstawiający sposób znajdowania pliku klienta SQL.

Zrzut ekranu przedstawiający sposób uruchamiania klienta SQL.

Jesteś teraz na kliencie SQL w języku Flink

Zapoznaj się z tym dokumentem, aby wykonać kilka kolejnych testów.

Flink udostępnia interfejs wiersza polecenia bin/flink umożliwiający uruchamianie programów spakowanych jako pliki JAR i kontrolowanie ich wykonywania.

Interfejs wiersza polecenia jest częścią protokołu Secure Shell (SSH) i łączy się z uruchomionym menedżerem zadań i używa konfiguracji klienta określonych w punkcie conf/flink-conf.yaml.

Przesłanie zadania oznacza przekazanie pliku JAR zadania do zasobnika SSH i zainicjowanie wykonania zadania. Aby zilustrować przykład dla tego artykułu, wybieramy długotrwałe zadanie, takie jak examples/streaming/StateMachineExample.jar.

Uwaga

W przypadku zarządzania zależnościami oczekiwana jest kompilacja i przesłanie tłuszczu jar dla zadania.

  • Przekaż plik jar zadania fat z usługi ABFS do protokołu Webssh.

  • W zależności od przypadku użycia musisz edytować konfiguracje klienta przy użyciu funkcji zarządzania konfiguracją Flink w obszarze flink-client-configs.

  • Uruchommy StateMachineExample.jar

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

Uwaga

Przesłanie zadania przy użyciu --detached spowoduje zwrócenie polecenia po zakończeniu przesyłania. Dane wyjściowe zawierają identyfikator nowo przesłanego zadania.

Odwołanie