Flink モニタリング
Flink(英語) プラグインを使用すると、 Apache Flink(英語) ジョブを監視して送信できます。
典型的なワークフロー:
Apache Flink ダッシュボードを反映した専用ツールウィンドウを使用して Flink ジョブを監視する
Flink サーバーに接続する
「Big Data Tools 」ウィンドウで「
」をクリックし、「Flink 」を選択します。開いた Big Data Tools ダイアログで、接続パラメーターを指定します。
名前: 他の接続と区別するための接続の名前。
URL: ApacheFlink ダッシュボードの URL を指定します。
オプションで、次を設定できます。
プロジェクト単位 ごと: これらの接続設定を現在のプロジェクトでのみ有効にするには、チェックボックスをオンにしてください。 この接続を他のプロジェクトでも表示したい場合は、チェックボックスをオフにしてください。
接続を有効にする: この接続を無効にする場合は、チェックボックスをオフにしてください。 デフォルトでは、新しく作成された接続は有効になっています。
トンネリングを有効にする: リモートホストへの SSH トンネルを作成します。 これは、ターゲットサーバーがプライベートネットワーク内にあるものの、ネットワーク内のホストへの SSH 接続が利用できる場合に便利です。
チェックボックスを選択し、SSH 接続の構成を指定します（... をクリックして新しい SSH 構成を作成します）。
HTTP 基本認証を使用可能にする: 指定されたユーザー名とパスワードを使用した HTTP 認証との接続。
プロキシ: IDE プロキシ設定を使用するか、カスタムプロキシ設定を指定するかを選択します。
設定を入力したら、 接続のテスト をクリックして、すべての構成パラメーターが正しいことを確認します。 次に OK をクリックします。
Flink サーバーへの接続を確立すると、Apache Flink ダッシュボードを反映した Flink ツールウィンドウが表示されます。
ジョブ、その構成、例外、チェックポイントをプレビューします。 フィルター フィールドを使用してジョブを名前でフィルタリングするか、 
をクリックしてステータスでフィルタリングします。 実行中のジョブがある場合は、 
をクリックして終了できます。
タスクを実行するノードを表示し、それらのログ、stdout、スレッドダンプを表示してダウンロードします。
Job Manager を表示し、ログと stdout を表示してダウンロードします。
アップロードされた JAR ファイルを表示し、名前またはエントリクラスでフィルタリングして、 新しい Flink ジョブを送信します。
新しいジョブを送信
Flink ツールウィンドウで、 新しいジョブを送信 タブを開きます。
アプリケーションの JAR ファイルがまだ Flink クラスターにアップロードされていない場合は、
をクリックして新しいファイルを選択します。アップロードされたファイルを選択し、
をクリックします。開いた JAR ファイルを提出する ウィンドウで、次のパラメーターを設定します。
復元されていない状態を許可する: 新しいプログラムにマップできないセーブポイントの状態のスキップを許可します (allowNonRestoredState(英語) オプションと同等)。
エントリクラス: プログラムエントリクラスに入る。
プログラム引数: プログラムの引数を入力します。
並列処理: タスクの並列インスタンスの数を入力します。 必要なタスクインスタンスが 1 つだけの場合は、空白のままにします。
セーブポイントパス: ジョブの実行状態イメージ (savepoint(英語)) のパスを入力します。
ジョブを送信したら、 ジョブタブでそのステータス、開始時刻、その他のパラメーターをプレビューできます。