データ統合ジョブの監視 > データ統合ジョブの監視 > コードタスクの監視
  

コードタスクの監視

特定のコードタスクに関する詳細情報を表示するには、[マイジョブ]ページでインスタンス名をクリックします。

ジョブのプロパティ

コードタスクインスタンスのジョブのプロパティでは、タスクの全般プロパティが表示されます。
次の表に、コードタスクのジョブのプロパティを示します。
プロパティ
説明
タスク名
タスクの名前。
インスタンスID
タスクのインスタンス番号。例えば、タスクの3番目の実行を見ている場合、このフィールドには「3」と表示されます。
タスクタイプ
、この場合はコードタスク。
CodeTask ID
コードタスクの一意の識別子。
開始したユーザー名
ジョブを開始したユーザーの名前。
開始時刻
ジョブが開始された日時。
終了時刻
ジョブが完了または停止した日時。
継続時間
完了または停止するまでにジョブが実行された時間。
ランタイム環境
ジョブが実行されたランタイム環境。
詳細設定
詳細設定エラスティッククラスタ詳細クラスタ
クラスタ
詳細クラスタエラスティックジョブ詳細ジョブ
クラスタ名をクリックして、クラスタの監視の詳細に直接移動できます。

ジョブの結果

コードタスクインスタンスのジョブの結果には、ジョブのステータスと、成功およびエラー統計が表示されます。
次の表に、コードタスクのジョブの結果を示します。
プロパティ
説明
ステータス
ジョブステータス。ジョブは、次のいずれかの状態になります。
  • - 起動。ジョブが開始されました。
  • - 実行中。ジョブはキューに入れられているか、実行中です。
  • - 成功。ジョブが正常に完了しました。
  • - 失敗しました。エラーが発生したため、ジョブは完了しませんでした。
セッションログ
セッションログファイルをダウンロードできます。デフォルトでは、Informatica Intelligent Cloud Servicesは、10回の実行のセッションログを格納してから、最新の実行でログを上書きします。
セッションログファイルは次のディレクトリに書き込まれます。
<Secure Agent installation directory>/apps/Data_Integration_Server/logs
要求された1時間あたりのコンピューティングユニット
1時間あたりのタスクが要求したサーバーレスコンピューティングユニット数。
タスクがサーバーレスランタイム環境で実行される場合、要求されたコンピューティングユニット数を表示できます。
使用されたコンピューティングユニットの合計
タスクが使用したサーバーレスコンピューティングユニットの合計数。
タスクがサーバーレスランタイム環境で実行される場合、使用されたコンピューティングユニット数を表示できます。
エラーメッセージ
ジョブに関連付けられているエラーメッセージ(ある場合)。

コードタスクAPI実行パラメータ

コードタスクインスタンスごとの実行パラメータは、タスクで使用されるAPIパラメータを表示します。
次の表に、コードタスクの実行パラメータを示します。
プロパティ
必須/オプション
説明
コードタスクのタイムアウトをオーバーライド
オプション
この実行のコードタスクタイムアウト値をオーバーライドします。値-1は、タイムアウトがないことを意味します。
ログレベル
オプション
セッションログ、エージェントジョブログ、Sparkドライバ、およびエグゼキューターログのログレベル。有効な値は、none、terse、normal、verboseInitialization、またはverboseDataです。
デフォルト値は[通常]です。
次の表に、コードタスクのSparkプロパティを示します。
プロパティ
必須/オプション
説明
Mainクラス
必須
Sparkアプリケーションのエントリポイント。以下に例を示します。
org.apache.spark.examples.company.SparkExampleApp
Mainクラスの引数
オプション
SparkアプリケーションのMainクラスに送信される順序付けされた引数。以下に例を示します。
--appTypeSPARK_PI_FILES_JARS--
classesToLoadcom.company.test.SparkTest1Class
プライマリリソース
必須
コードタスクが含まれているScala JARファイル。
JARファイルパス
オプション
クラスタにアップロードされ、Sparkドライバとエグゼキュータークラスパスに追加されるJARファイルのディレクトリとファイル名。
Sparkファイルパス
オプション
クラスタにアップロードされ、現在の作業ディレクトリで利用できるSparkファイルのディレクトリとファイル名。
カスタムプロパティ
オプション
データ統合が使用するSparkプロパティまたはその他のカスタムプロパティ。

Sparkアプリケーションタスクの詳細

コードタスクのSparkアプリケーションタスクの詳細は、[Sparkアプリケーションタスクの結果]の下に表示されます。
各Sparkアプリケーションタスクには次の詳細が含まれます。
プロパティ
説明
ステータス
Sparkタスクのステータス。Sparkタスクのステータスは次のいずれかです。
  • - 実行中。タスクは実行中です。
  • - 成功。タスクが正常に完了しました。
  • - 失敗しました。エラーが発生したため、タスクは完了しませんでした。
  • - 停止。タスクは停止しました。
  • - 不明。タスクのステータスは不明です。
ジョブの実行中にSecure Agentで障害が発生した場合、Sparkタスクのステータスは「実行中」という表示のままになります。ジョブをキャンセルして、実行し直す必要があります。
開始時刻
Sparkタスクの開始日時。
終了時刻
Sparkタスクの終了日時。
継続時間
Sparkタスクが実行された時間。
Executorあたりのメモリ
各Spark Executorが使用するメモリの量。
Executorあたりのコア数
各Spark Executorが使用するコアの数。
ドライバおよびエージェントジョブログ
[ダウンロード]を選択して、Sparkドライバとエージェントジョブログをダウンロードします。
詳細ログの場所
詳細クラスタについて、詳細設定で設定されているログの場所。詳細ログの場所に移動して、エージェントジョブログ、Sparkドライバログ、およびSpark Executorログを表示およびダウンロードできます。
エラーメッセージ
ジョブに関連付けられているエラーメッセージ(存在する場合)。
それぞれのSparkアプリケーションタスクはSparkジョブに変換され、さらにステージに分割されます。Sparkジョブおよびステージごとに次の詳細を表示できます。
プロパティ
説明
ジョブ名
Sparkジョブまたはステージの名前。
継続時間
Sparkジョブまたはステージが実行された時間。
タスクの合計
Sparkジョブまたはステージが試行したタスクの数。
失敗したタスク
Sparkジョブまたはステージが完了できなかったタスクの数。
入力サイズ/レコード数
Sparkジョブまたはステージによって入力されたファイルのサイズとレコードの数。
出力サイズ/レコード数
Sparkジョブまたはステージによって出力されたファイルのサイズとレコードの数。
ステータス
Sparkジョブまたはステージのステータス。ステータスは、次のいずれかの値になります。
  • - 実行中。ジョブまたはステージが実行中。
  • - 成功。ジョブまたはステージが正常に完了。
  • - 失敗しました。エラーが発生したため、ジョブまたはステージは完了しませんでした。
  • - 強制終了。ユーザーがコードタスクを強制終了したため、ジョブまたはステージは完了しませんでした。
注: コードタスクを強制終了した後に、Monitorサービスにステータスが[強制終了]と表示されるまでに多少の遅延時間が発生する場合があります。