共用方式為

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

  • 發行項

重要

AKS 上的 Azure HDInsight 於 2025 年 1 月 31 日淘汰。 透過此公告 深入瞭解。

您必須將工作負載移轉至 Microsoft Fabric 或對等 Azure 產品，以避免突然終止工作負載。

重要

這項功能目前為預覽狀態。 Microsoft Azure 預覽版的補充使用規定 包含適用於 Beta 版、預覽版或尚未正式發行之 Azure 功能的更合法條款。 如需此特定預覽的相關資訊，請參閱 Azure HDInsight on AKS 預覽資訊。 如需問題或功能建議，請在 AskHDInsight 提交請求，並關注我們以取得 Azure HDInsight 社群的更多更新。

此範例將說明如何在 Azure 入口網站上使用 SSH 進入 AKS 叢集中的 HDInsight 上的 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 提供 Command-Line 介面 （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-configs 底下的 Flink 組態管理來編輯用戶端組態。

  • 讓我們執行StateMachineExample.jar

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

注意

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

參考