Udostępnij za pośrednictwem

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żny

Usługa Azure HDInsight w usłudze AKS została wycofana 31 stycznia 2025 r. Dowiedz się więcej z tego ogłoszenia .

Aby uniknąć nagłego kończenia obciążeń, należy przeprowadzić migrację obciążeń do usługi Microsoft Fabric lub równoważnego produktu platformy Azure.

Ważny

Ta funkcja jest obecnie dostępna w wersji zapoznawczej. Dodatkowe warunki użytkowania Microsoft Azure zawierają więcej warunków prawnych, które dotyczą funkcji Azure w wersji beta, w wersji zapoznawczej lub w inny sposób jeszcze nie udostępnione ogólnie. Aby uzyskać informacje na temat tej konkretnej wersji zapoznawczej, zobacz Azure HDInsight w usłudze AKS w wersji zapoznawczej informacji. W przypadku pytań lub sugestii dotyczących funkcji, prosimy o przesłanie zgłoszenia na AskHDInsight wraz ze szczegółami i śledzenie nas, aby uzyskać więcej informacji o społeczności Azure HDInsight.

W tym przykładzie przedstawiono, jak uzyskać dostęp do klienta Apache Flink CLI w usłudze HDInsight na klastrach AKS przy użyciu protokołu SSH w portalu Azure. Omawiamy zarówno SQL, jak i Flink DataStream.

Warunki wstępne

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

Nawiązywanie połączenia z protokołem SSH z poziomu witryny Azure Portal

Po utworzeniu klastra Flink możesz obserwować w lewym okienku opcję Ustawienia , aby uzyskać dostęp do Secure Shell

Zrzut ekranu przedstawiający sposób tworzenia POD-a i nawiązywania połączenia z siecią WebSSH.

Nawiązywanie połączenia z klientem SQL

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

Zrzut ekranu przedstawiający znajdowanie pliku klienta SQL.

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

Korzystasz teraz z klienta SQL na platformie Flink

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

Flink udostępnia interfejs Command-Line (CLI) bin/flink do uruchamiania programów spakowanych jako pliki JAR i kontrolowania 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 conf/flink-conf.yaml.

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

Notatka

W przypadku zarządzania zależnościami oczekuje się kompilacji i przesłania fat jar dla zadania.

  • Przekaż plik typu fat jar dla zadania z usługi ABFS do webssh.

  • Na podstawie Twojego przypadku użycia, należy edytować konfiguracje klienta przy użyciu zarządzanie konfiguracją Flink w obszarze flink-client-configs.

  • Uruchommy plik 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.

Odniesienie