ワークフローを作成した後、そのワークフロー実行とワークフローノード実行を管理できます。このトピックでは、ワークフロー実行の表示、ノードログの確認、およびその他の操作を実行する方法について説明します。
前提条件
ワークフローを作成して実行しておく必要があります。詳細については、「ワークフローの管理」をご参照ください。
ワークフロー実行の表示
-
「ワークフロー」ページに移動します。
-
E-MapReduce コンソールにログインします。
-
左側のナビゲーションウィンドウで、[EMR Serverless] > [Spark] を選択します。
-
[Spark] ページで、対象のワークスペースの名前をクリックします。
-
EMR Serverless Spark ページで、左側のナビゲーションウィンドウの タスクオーケストレーション をクリックします。
-
-
タスクオーケストレーション ページで、目的のワークフローの名前をクリックします。
Workflow Runs ページが表示されます。
-
各ワークフロー実行の期間と実行ステータスを表示できます。
-
Workflow Runs リストで Workflow Run ID をクリックするか、Workflow Run Graph タブをクリックすると、対応するグラフが表示されます。各ワークフローノードの実行の色は、その実行ステータスを示します。詳細については、「実行ステータスを表示する」をご参照ください。
-
ワークフローノード実行の表示
-
「ワークフロー」ページに移動します。
-
E-MapReduce コンソールにログインします。
-
左側のナビゲーションウィンドウで、EMR Serverless > Spark を選択します。
-
[Spark] ページで、対象のワークスペースの名前をクリックします。
-
EMR Serverless Spark ページで、左側のナビゲーションウィンドウの タスクオーケストレーション をクリックします。
-
-
タスクオーケストレーション ページで、対象のワークフロー名をクリックします。
-
Workflow Run Graph タブをクリックします。
-
ワークフローノード実行をクリックします。ノード詳細ダイアログボックスで、情報を表示したり、操作を実行したりできます。
操作
説明
Details をクリックします。
次の情報が表示されます：
-
Node Instance Information: ジョブ ID、ノードの開始時刻、ジョブ実行 ID など、現在のワークフローノードの実行に関する詳細を表示します。
-
Code: 現在のワークフローノードの実行に関連付けられたジョブのコードを表示します。
-
Logs: 現在のワークフローノード実行のログを表示します。
Spark UIをクリックします。
Spark ジョブページが開き、ステータス、タスクの進捗、リソース使用量などのリアルタイムのジョブ詳細を表示できます。
Rerun をクリックします。
現在のジョブを再実行します。
Downstream Nodes を選択して Rerun をクリックすると、システムは、選択された下流ノードを含むすべての関連ジョブを、ワークフローで定義された論理的な順序で再実行します。
Terminate をクリックします。
実行中のノードを停止し、そのステータスを「失敗」に設定します。
Mark Success をクリックします。
失敗したノードのステータスを「成功」に変更します。
Downstream Nodes を選択してから Mark Success をクリックすると、システムは、ワークフローで定義されている論理的な順序に従い、失敗状態にある選択されたノードを成功状態に設定します。
Job Run ID の横にあるリンクをクリックします。
ジョブ履歴内のジョブの概要ページが開き、その基本情報と設定が表示されます。
-