Flink モニタリング

Flink サーバーに接続する

1. ビッグデータツールウィンドウで をクリックし、Flink を選択します。

2. 開いたビッグデータツールダイアログで、接続パラメーターを指定します。

   

   • 名前 : 他の接続と区別するための接続の名前。

   • URL : ApacheFlink ダッシュボードの URL を指定します。

   オプションで、次を設定できます。

   • プロジェクトごと: これらの接続設定を現在のプロジェクトでのみ有効にする場合に選択します。この接続を他のプロジェクトで表示する場合は、選択を解除します。

   • 接続を使用可能にする : この接続を無効にする場合は選択を解除します。デフォルトでは、新しく作成された接続は有効になっています。

   • トンネリングを有効にする : リモートホストへの SSH トンネルを作成します。ターゲットサーバーがプライベートネットワーク内にあるが、ネットワーク内のホストへの SSH 接続が利用可能な場合に役立ちます。

     チェックボックスを選択し、SSH 接続の構成を指定します（... をクリックして新しい SSH 構成を作成します）。

   • HTTP 基本認証を使用可能にする : 指定されたユーザー名とパスワードを使用した HTTP 認証との接続。

   • プロキシ : IDE プロキシ設定を使用するか、カスタムプロキシ設定を指定するかを選択します。

3. 設定を入力したら、接続のテストをクリックして、すべての構成パラメーターが正しいことを確認します。次に OK をクリックします。

新しいジョブを送信

1. Flink ツールウィンドウで、新しいジョブを送信タブを開きます。

2. アプリケーションの JAR ファイルがまだ Flink クラスターにアップロードされていない場合は、 をクリックして新しいファイルを選択します。

3. アップロードされたファイルを選択し、 をクリックします。

4. 開いた JAR ファイルを提出するウィンドウで、次のパラメーターを設定します。

   • 復元されていない状態を許可する : 新しいプログラムにマップできないセーブポイントの状態のスキップを許可します (allowNonRestoredState(英語) オプションと同等)。

   • エントリクラス : プログラムエントリクラスに入る。

   • プログラム引数 : プログラムの引数を入力します。

   • 並列処理 : タスクの並列インスタンスの数を入力します。必要なタスクインスタンスが 1 つだけの場合は、空白のままにします。

   • セーブポイントパス : ジョブの実行状態イメージ (savepoint(英語)) のパスを入力します。

   

ジョブを送信したら、ジョブタブでそのステータス、開始時刻、その他のパラメーターをプレビューできます。