在具有 Azure 入口網站 的 AKS 叢集上使用 HDInsight 上的安全殼層 （SSH） 存取 Apache Flink® CLI 用戶端

重要

此功能目前為預覽功能。 適用於 Microsoft Azure 預覽版的補充使用規定包含適用於 Beta 版、預覽版或尚未發行至正式運作之 Azure 功能的更合法條款。 如需此特定預覽的相關信息，請參閱 AKS 預覽資訊的 Azure HDInsight。 如需問題或功能建議，請在 AskHDInsight 上提交要求，並提供詳細數據，並遵循我們在 Azure HDInsight 社群上取得更多更新。

本範例會引導如何在 AKS 叢集上使用 SSH 在 AKS 叢集上輸入 Apache Flink CLI 用戶端，Azure 入口網站，我們同時涵蓋 SQL 和 Flink DataStream。

必要條件

• 您必須在建立 Flink 叢集期間選取 SSH

從 Azure 入口網站 連線到 SSH 連線

建立 Flink 叢集之後，您可以在左窗格中觀察存取安全殼層 設定 選項

Apache Flink SQL

連線 至 SQL 用戶端

您必須將目錄變更為 /opt/flink-webssh/bin ，然後執行 ./sql-client.sh

您現在位於 Flink 上的 SQL 用戶端

請參閱本檔以執行更多測試。

Apache Flink DataStream

Flink 提供命令行介面 （CLI） bin/flink 來執行封裝為 JAR 檔案並控制其執行的程式。

CLI 是安全殼層 （SSH） 的一部分，它會連線到執行中的 JobManager，並使用 在 conf/flink-conf.yaml指定的用戶端組態。

提交作業表示將作業的 JAR 上傳至 SSH Pod 並起始作業執行。 為了說明本文的範例，我們會選取長時間執行的作業，例如 examples/streaming/StateMachineExample.jar。

注意

若要管理相依性，預期是建置並提交工作的 fat jar。

• 將 fat job jar 從 ABFS 上傳至 webssh。

• 根據您的使用案例，您必須使用 flink-client-config 下的 Flink 組態管理 來編輯用戶端組態。

• 讓我們執行StateMachineExample.jar

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

注意

使用 --detached 提交作業時，會讓命令在提交完成後傳回。 輸出包含新送出作業的識別碼。

參考

• Flink SQL 用戶端
• Apache、Apache Flink、Flink 和相關聯的開放原始碼專案名稱為 Apache Software Foundation (ASF) 的 商標。