共用方式為

使用 Azure 入口網站在 HDInsight on AKS 叢集上使用安全殼層 (SSH) 來存取 Apache Flink® CLI 用戶端

  • 發行項

注意

我們將在 2025 年 1 月 31 日淘汰 Azure HDInsight on AKS。 在 2025 年 1 月 31 日之前，您必須將工作負載移轉至 Microsoft Fabric 或對等 Azure 產品，以避免工作負載突然終止。 訂用帳戶上的剩餘叢集將會停止並從主機中移除。

重要

此功能目前為預覽功能。 Microsoft Azure 預覽版增補使用規定包含適用於 Azure 功能 (搶鮮版 (Beta)、預覽版，或尚未正式發行的版本) 的更多法律條款。 若需此特定預覽版的相關資訊，請參閱 Azure HDInsight on AKS 預覽版資訊。 如有問題或功能建議，請在 AskHDInsight 上提交要求並附上詳細資料，並且在 Azure HDInsight 社群上追蹤我們以獲得更多更新資訊。

此範例將引導您經由 Azure 入口網站使用 SSH 在 HDInsight on AKS 叢集上進入 Apache Flink CLI 用戶端，我們同時涵蓋 SQL 和 Flink DataStream。

必要條件

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

從 Azure 入口網站連線到 SSH

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

顯示如何建立 POD 並連線至 Webssh 的螢幕擷取畫面。

連線到 SQL 用戶端

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

如何尋找 sql 用戶端檔案的螢幕擷取畫面。

顯示如何執行 SQL 用戶端的螢幕擷取畫面。

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

若要執行更多測試，請參閱這份文件。

Flink 提供 命令列介面 (CLI) bin/flink，以執行封裝為 JAR 檔案的程式及控制其執行。

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

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

注意

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

  • 將 fat 作業 jar 從 ABFS 上傳至 webssh。

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

  • 讓我們執行 StateMachineExample.jar

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

注意

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

參考