次の方法で共有

AKS クラスター上の HDInsight 上の Apache Flink® コマンド ライン インターフェイス (CLI)

  • [アーティクル]

Note

Azure HDInsight on AKS は 2025 年 1 月 31 日に廃止されます。 2025 年 1 月 31 日より前に、ワークロードを Microsoft Fabric または同等の Azure 製品に移行することで、ワークロードの突然の終了を回避する必要があります。 サブスクリプション上に残っているクラスターは停止され、ホストから削除されることになります。

提供終了日までは基本サポートのみが利用できます。

重要

現在、この機能はプレビュー段階にあります。 ベータ版、プレビュー版、または一般提供としてまだリリースされていない Azure の機能に適用されるその他の法律条項については、「Microsoft Azure プレビューの追加の使用条件」に記載されています。 この特定のプレビューについては、「Microsoft HDInsight on AKS のプレビュー情報」を参照してください。 質問や機能の提案については、詳細を記載した要求を AskHDInsight で送信してください。また、その他の更新情報については、Azure HDInsight コミュニティのフォローをお願いいたします。

Apache Flink には、JAR ファイルとしてパッケージ化されたジョブ (プログラム) を実行し、その実行を制御するための CLI (コマンド ライン インターフェイス) bin/flink が用意されています。 この CLI は Flink のセットアップに含まれており、単一ノード VM で設定できます。 conf/flink-conf.yaml で指定された実行中の JobManager に接続します。

インストール手順

Linux に Flink CLI をインストールするには、インストール スクリプトを実行するための Linux VM が必要です。 Windows を使用している場合は、bash 環境を実行する必要があります。

Note

これは、Windows GIT BASH では機能しません。これを Windows で機能させるには、WSL をインストールする必要があります。

必要条件

  • JRE 11 をインストールします。 インストールされていない場合は、/java/openjdk/download で説明されている手順に従います。
  • PATH に java を追加するか、JRE インストール・ディレクトリーを指す JAVA_HOME 環境変数を $JAVA_HOME/bin/java が存在するように定義します。

インストールまたは更新

CLI をインストールおよび更新するには、いずれの場合もインストール スクリプトを再実行する必要があります。 curl を実行して CLI をインストールします。

curl -L https://aka.ms/hdionaksflinkcliinstalllinux | bash

Flink 1.17 を使用している場合は、以下の CLI を使用できます

curl -L https://aka.ms/hdionaksflink117clilinux | bash

このコマンドは、ユーザーのホーム ディレクトリ ($HOME/flink-cli) に Flink CLI をインストールします。 スクリプトをダウンロードして、ローカルで実行することもできます。 変更を有効にするには、シェルを再起動する必要がある場合があります。

cd $HOME/flink-cli 

bin/flink list -D azure.tenant.id=<update-tenant-id> -D rest.address=<flink-cluster-fqdn>

Note

SSH ポッド経由で実行する場合は、コマンド bin/flink list を使用して完全な出力を提供します。

これらのパラメーターを毎回追加したくない場合は、それらを conf/flink-conf.yaml に追加します。

rest.address: <flink-cluster-fqdn>
azure.tenant.id: <tenant-id>

コマンドは次のようになります

bin/flink list

次のような出力結果が表示されます。

To sign in, use a web browser to open the page https://microsoft.com/devicelogin and enter the code E4LW35GFD to authenticate.

ブラウザーで https://microsoft.com/devicelogin を開き、コードを入力してから、microsoft.com ID を使用してログインします。 ログインに成功すると、ジョブが実行されていない場合は次のような出力が表示されます。

Waiting for response...
No running jobs.
No scheduled jobs.

curl Object Moved エラー

curl で -L パラメーターに関連するエラーが発生した場合や、"Object Moved" というテキストが含まれているエラー メッセージが表示された場合は、次のように、aka.ms リダイレクトの代わりに完全な URL を使用してみてください。

curl https://hdiconfigactions.blob.core.windows.net/hiloflinkblob/install.sh | bash

例

Flink の CLI ツールでサポートされるアクションの例を次に示します。

アクション 目的
[実行] このアクションはジョブを実行します。 ジョブを含む jar が少なくとも必要です。 Flink またはジョブ関連の引数を、必要に応じて渡すことができます。
info このアクションを使用すると、渡されたジョブの最適化された実行グラフを出力できます。 また、ジョブを含む jar を渡す必要があります。
list このアクションは、"実行中またはスケジュールされたすべてのジョブを一覧表示します"。
savepoint このアクションを使用すると、特定のジョブの "セーブポイントを作成または破棄" できます。 JobID 以外にセーブポイント ディレクトリを指定することが必要な場合があります。
cancel このアクションを使用すると、JobID に基づいて "実行中のジョブを取り消す" ことができます。
stop このアクションは、"cancel アクションと savepoint アクション" を組み合わせて実行中のジョブを停止しますが、再び開始するセーブポイントも作成します。

すべてのアクションとそのパラメーターには、次のコマンドを使用してアクセスできます。

bin/flink --help

個々のアクションの使用状況情報

bin/flink <action> --help

ヒント

  • 接続をブロックするプロキシがある場合、インストール スクリプトを取得するには、プロキシでアドレス https://aka.ms/ および https://hdiconfigactions.blob.core.windows.net への HTTPS 接続を許可する必要があります。
  • この問題を解決するには、承認プロファイルにユーザーまたはグループを追加します。

リファレンス