データバックフィルは、過去または未来の期間のタスクを実行し、対応する時間ベースのパーティションに出力を書き込みます。コード内のスケジューリングパラメーターは、選択されたビジネス日付に基づいて特定の値に自動的に置き換えられます。実際に書き込まれるパーティションは、タスクコード内のロジックに依存します。
権限要件
データバックフィルチェーンに沿ったすべてのタスクに対する操作権限が必要です。いずれかのタスクに対する権限がない場合、以下の結果となります。
-
直接のターゲットタスクに対する権限がない場合:データバックフィルのルートタスクまたはその下流タスクのいずれかに対する操作権限がない場合、データバックフィルは実行できません。
-
中間タスクに対する権限がない場合:権限のないタスクがこのデータバックフィルの中間ノードである場合 (その上流タスクと下流タスクの両方がデータバックフィルの範囲内にある場合)、システムはそのタスクに対してドライランを実行します。
-
ドライランの説明:タスクが開始された後、実際の計算ロジックは実行されません。すぐに成功ステータスを返し、その下流タスクがトリガーされるようにします。
-
リスク警告:ドライランとして実行される中間タスクは実際のデータを生成しないため、その下流タスクが異常な出力を生成したり、入力不足で失敗したりする可能性があります。注意して実行してください。
-
注意事項
データバックフィル操作を実行する前に、以下のランタイムルールを確認してください。
1. インスタンスのライフサイクルとログ保持
-
インスタンスのクリーンアップ:データバックフィルインスタンスは手動で削除できません。作成後約 30 日で自動的にクリーンアップされます。実行する必要がなくなったタスクのスケジューリングを停止するには、そのインスタンスをフリーズしてください。
-
保持ポリシー:インスタンスとログの保持期間は、リソースグループの種類によって異なります。
リソースグループの種類
インスタンス保持ポリシー
ログ保持ポリシー
スケジューリング用共有リソースグループ
30 日
7 日
専用スケジューリングリソースグループ
30 日
30 日
サーバーレスリソースグループ
30 日
30 日
-
大規模ログのクリーンアップ:完了したインスタンスで 3 MB を超えるランタイムログは、日次スケジュールでクリーンアップされます。
2. インスタンスのランタイムルール
-
日単位の厳密な依存関係:データバックフィルは、ビジネス日付ごとにシリアルに実行されます。次の日のインスタンスは、前の日のすべてのインスタンスが成功した後にのみ開始されます。いずれかのインスタンスが失敗した場合、後続のすべての日付がブロックされます。
-
日をまたぐ依存関係は有効にならない:タスク間の日をまたぐ依存関係は、データバックフィル中は有効になりません。複数日にまたがる期間のタスクをバックフィルする場合、元の日をまたぐ依存関係の設定に関係なく、次の日のインスタンスは前の日のすべてのインスタンスが完了した後にのみ実行されます。
-
指定された範囲/セット依存関係の日をまたぐ処理:日をまたぐ指定された範囲またはセットタイプの依存関係の場合、データバックフィルインスタンスが生成されるときに、同日の依存関係のみが追加されます。日をまたぐ依存関係は自動的に無視されます。
-
時間単位/分単位タスクの同時実行動作:特定の日付のすべてのインスタンスをバックフィルする場合、同時実行数はタスクの自己依存属性によって決まります。
-
自己依存が設定されていない場合:日内のすべてのインスタンス (例:00:00、01:00 など) は、それぞれの上流依存関係が満たされている限り、グループで実行できます。
-
自己依存が設定されている場合:日内のすべてのインスタンスは厳密にシリアルに実行されます (例:01:00 のインスタンスは 00:00 のインスタンスが成功した後にのみ実行されます)。
-
-
定期インスタンスとの競合:定期インスタンスはデータバックフィルインスタンスよりも優先されます。両方が同時に実行される場合は、手動でデータバックフィルインスタンスを終了してください。
-
ブラックリストに登録されたタスクの処理:ブラックリストに登録されたタスクがデータバックフィルチェーンの中間ノードである場合、そのタスクもドライランとして実行され、下流タスクのデータ出力に影響を与える可能性があります。
3. スケジューリングリソースと優先度
-
リソースの合理的な設定:データバックフィルインスタンスが多すぎる、または並列処理が過剰であると、スケジューリングリソースを消費し、定期タスクに影響を与える可能性があります。それに応じて設定を計画してください。
-
優先度ダウングレードポリシー:プラットフォームは、データバックフィルのビジネス日付に基づいてタスクの優先度を動的に調整します。
-
昨日 (T-1) のデータのバックフィル:タスクの優先度は変更されず、それが属するベースラインの優先度によって決まります。
-
過去 (T-2 以前) のデータのバックフィル:タスクは以下のルールに従って自動的にスペックダウンされます。
-
元のレベル 7 または 8 → レベル 3 にスペックダウン
-
元のレベル 5 または 3 → レベル 2 にスペックダウン
-
元のレベル 1 → 変更なし
-
-
データバックフィルタスクの作成
ステップ 1: データバックフィルページへ移動
DataWorks コンソールにログインします。 対象のリージョンで、左側のナビゲーションウィンドウでをクリックします。 ドロップダウンリストからワークスペースを選択し、移動 オペレーションセンターをクリックします。
-
左側のナビゲーションウィンドウで、 をクリックして、データバックフィルページに移動します。
特定の定期タスクのデータをバックフィルするには、 ページに移動し、対応するタスクの横にある データバックフィル をクリックすることもできます。
ステップ 2: データバックフィルタスクの作成
データバックフィルページで、データバックフィルタスクの作成 をクリックし、ビジネス要件に基づいてデータバックフィルタスクを設定します。
-
設定 基本情報。
プラットフォームはデフォルトのフォーマットでデータバックフィル名を自動的に生成します。必要に応じて変更できます。
-
バックフィルするタスクを選択します。
手動選択、トレース別、ワークスペース別、指定タスクおよびすべての下流 などのメソッドを使用して、操作権限のあるタスクのデータバックフィルを開始し、そのタスクに基づいてバックフィルする他のタスクを選択できます。設定パラメーターはメソッドによって異なります。
手動選択
1 つ以上のタスクをルートタスクとして選択し、その下流タスクをこのデータバックフィルの範囲として選択します。このメソッドは、以前の現在のノード、現在のノードと子孫ノード、および詳細モードのデータバックフィルソリューションと互換性があります。
パラメーターは以下のとおりです。
パラメーター
説明
方法
手動選択 を選択します。
ルートタスクの検索
名前または ID でルートタスクを検索して追加します。バッチ追加 をクリックして、リソースグループ、スケジュール、またはワークスペースでフィルターをかけ、複数のルートタスクをバッチで追加することもできます。
説明参加しているワークスペース (つまり、メンバーであるワークスペース) のタスクのみを選択できます。
選択済みデータバックフィルリスト
バックフィルするタスク。リストには追加されたルートタスクが表示され、そこから含める下流タスクを選択できます。
説明-
依存関係レベルで下流タスクをフィルターできます。ルートタスクの直接の下流タスクはデフォルトでレベル 1 であり、以下同様です。
-
一度に最大 500 個のルートタスクをバックフィルでき、合計で最大 2000 個のタスク (ルートタスクとその下流タスク) (中国 (北京) および中国 (杭州) リージョンでは 3000) をバックフィルできます。
-
タスクに最大並列インスタンス数が設定されている場合、データバックフィルインスタンスもこの制限の対象となり、定期インスタンスと同時実行クォータを共有します。
タスクブラックリスト
タスクをバックフィルする必要がない場合は、ブラックリストに追加できます。ブラックリスト内のタスクは、このデータバックフィルには参加しません。
説明-
ルートタスクのみをブラックリストに追加できます。ルートタスクの子タスクをバックフィルする必要がない場合は、[選択されたデータバックフィルリスト] から削除してください。
-
ブラックリスト内のタスクがこのデータバックフィルの中間タスクである場合 (つまり、その上流および下流の依存関係がこのデータバックフィルの範囲内にある場合)、タスクはドライランとして実行され、下流タスクの実行を保証します (実際には実行されず、開始後すぐに成功ステータスを返します) が、これによりこのタスクの下流タスクのデータ出力が異常になる可能性があります。
チェーンで選択
開始タスクと 1 つ以上の終了タスクを選択します。プラットフォームは、それらの間のすべてのタスクをこのデータバックフィルの範囲として自動的に識別します (開始タスクと終了タスクを含む)。
パラメーターは以下のとおりです。
パラメーター
説明
方法
トレース別 を選択します。
[タスクの検索]
名前または ID で検索して、開始タスクと 1 つ以上の終了タスクを追加します。プラットフォームは、開始タスクと終了タスクに基づいて中間タスクを識別します (中間タスクは、開始タスクの直接または間接の下流タスクであり、終了タスクの直接または間接の上流タスクです)。
[中間タスクリスト]
プラットフォームが開始タスクと終了タスクに基づいて自動的に識別した中間タスク。
説明リストには 2000 個のタスクのみが表示されます。2000 を超えるタスクは表示されませんが、正常に実行されます。
タスクブラックリスト
タスクをバックフィルする必要がない場合は、ブラックリストに追加できます。ブラックリスト内のタスクは、このデータバックフィルには参加しません。
説明ブラックリスト内のタスクがこのデータバックフィルの中間タスクである場合 (つまり、その上流および下流の依存関係がこのデータバックフィルの範囲内にある場合)、タスクはドライランとして実行され、下流タスクの実行を保証します (実際には実行されず、開始後すぐに成功ステータスを返します) が、これによりこのタスクの下流タスクのデータ出力が異常になる可能性があります。
ワークスペースで選択
タスクをルートタスクとして選択し、その下流ノードのワークスペースに基づいてバックフィル範囲を決定します。このメソッドは、以前の大量ノードモードのデータバックフィルソリューションと互換性があります。
説明-
以前の 大規模ノードパターン データバックフィルソリューションと互換性があります。
-
タスクブラックリストの設定はサポートされていません。
パラメーターは以下のとおりです。
パラメーター
説明
方法
ワークスペース別 を選択します。
ルートタスクの検索
名前または ID でルートタスクを検索して追加します。プラットフォームは、ルートタスクの下流タスクのワークスペース内のタスクをバックフィルします。
説明参加しているワークスペース (つまり、メンバーであるワークスペース) のタスクのみを選択できます。
[ルートノードを含める]
このデータバックフィルにルートタスクを含めるかどうかを指定します。
データバックフィルワークスペース
ルートタスクの下流タスクのワークスペースに基づいて、バックフィルするノードを持つワークスペースを選択します。
説明-
データバックフィル操作には、現在のリージョンの DataWorks ワークスペースのみを選択できます。
-
ワークスペースを選択すると、デフォルトでワークスペース内のすべてのノードがバックフィルされます。必要に応じて、データバックフィルのホワイトリストとブラックリストをカスタマイズできます。
タスクのホワイトリスト
選択したワークスペースに含まれるノードに加えて、バックフィルする必要があるノード。
タスクブラックリスト
選択したワークスペース内でバックフィルする必要がないノード。
タスクとすべての子孫タスクを指定
ルートタスクを選択すると、プラットフォームは自動的にそのタスクとすべての子孫タスクをこのデータバックフィルの範囲として識別します。
重要トリガーされたタスクは、データバックフィルタスクの実行中にのみ確認できます。注意して使用してください。
パラメーターは以下のとおりです。
パラメーター
説明
方法
指定タスクおよびすべての下流 を選択します。
ルートタスクの検索
名前または ID でルートタスクを検索して追加します。プラットフォームは、ルートタスクとそのすべての子孫タスクをバックフィルします。
説明-
参加しているワークスペース (つまり、メンバーであるワークスペース) のタスクのみを選択できます。
-
選択したルートタスクに子孫タスクがない場合、データバックフィルタスクが送信された後、現在のルートタスクのデータのみがバックフィルされます。
タスクブラックリスト
タスクをバックフィルする必要がない場合は、ブラックリストに追加できます。ブラックリスト内のタスクは、このデータバックフィルには参加しません。
説明ブラックリスト内のタスクがこのデータバックフィルの中間タスクである場合 (つまり、その上流および下流の依存関係がこのデータバックフィルの範囲内にある場合)、タスクはドライランとして実行され、下流タスクの実行を保証します (実際には実行されず、開始後すぐに成功ステータスを返します) が、これによりこのタスクの下流タスクのデータ出力が異常になる可能性があります。
-
データバックフィルのランタイムポリシーを設定します。
ビジネス要件に基づいて、データバックフィルタスクのランタイム、グルーピング、アラート、およびリソースグループの設定を行います。
パラメーターは以下のとおりです。
パラメーター
説明
データタイムスタンプ
バックフィルするビジネス日付を指定します。手動入力、AI ベースの生成、およびバッチ入力がサポートされています。
システムは、選択した日付とオプションに応じて異なる実行ポリシーを使用します。
シナリオ 1: 過去のデータをバックフィルする (ビジネス日付 < 現在の日付)
これは最も一般的なシナリオです。選択したビジネス日付が今日より前の場合、システムはすぐにその日付のタスクインスタンスを作成して実行し、過去のデータを再計算します。
-
目的:過去のデータエラーを修正するか、欠落しているデータを補完します。
-
実行モード:すぐに実行。
シナリオ 2: 将来のタスクをスケジュールする (ビジネス日付 > 現在の日付)
特別なオプションなしで将来のビジネス日付を選択した場合、これはその将来の日付に対して 1 回限りの定期タスクを作成するのと同じです。
-
目的:特定の将来の日付に対して 1 回限りのタスク実行をスケジュールします。
-
実行モード:スケジュール時に実行。インスタンスは待機状態で作成され、対応するビジネス日付が来るとタスクのスケジュール設定に基づいて自動的に実行されます。
シナリオ 3: スケジュール時刻が現在時刻より後のインスタンスをすぐに実行する ([すぐに実行] を選択)
現在時刻より後にスケジュールされたデータバックフィルインスタンスをすぐに実行します。 は高度なオプションです。ビジネス日付が現在の日付より後である場合、またはビジネス日付が T-1 であり、タスクにスケジュール時刻が現在時刻より後のインスタンスが含まれている場合に表示されます。選択すると、スケジュール時刻が現在時刻より後のインスタンスは、スケジュール時刻を待たずにすぐに実行されます。
-
目的:将来の日付のタスクインスタンスを前もって実行し、移行やテストのために特定のパーティションのデータを準備したり、T-1 データをバックフィルする際にスケジュール時刻がまだ来ていない時間単位または分単位のインスタンスをすぐに実行したりします。
-
実行モード:選択後すぐに実行。
-
例 1 (将来のデータのバックフィル):現在の日付が
2024-03-12で、2024-03-17のデータをバックフィルすることを選択し、現在時刻より後にスケジュールされたデータバックフィルインスタンスをすぐに実行します。 を選択します。この場合、タスクインスタンスは2024-03-12にすぐに開始されますが、実行時に使用するビジネス日付パラメーター (データパーティションなどに影響) は2024-03-17です。 -
例 2 (T-1 データのバックフィル):現在の時刻が
2024-03-12 14:30で、2024-03-11(T-1) のデータをバックフィルすることを選択します。タスクは時間単位でスケジュールされています (1 時間に 1 回実行)。このオプションを選択しない場合、15:00、16:00、および 14:30 より後の他の時刻にスケジュールされたインスタンスは、それぞれのスケジュール時刻まで待つ必要があります。現在時刻より後にスケジュールされたデータバックフィルインスタンスをすぐに実行します。 を選択すると、すべてのインスタンスがすぐに実行されます。
説明-
ビジネス日付の概念:バッチコンピューティングでは、タスクは通常、今日 (T) に前日 (T-1) のデータを処理します。データバックフィルは、指定されたビジネス日付のインスタンスを生成するため、タスクがどの日付のデータを処理するかを制御できます。
-
複数の期間:連続していない複数の日付のデータをバックフィルするには、[追加] をクリックして複数の期間を設定します。
-
リソース計画:単一のデータバックフィルに長すぎる期間を設定しないでください。多数のインスタンスはスケジューリングリソースを消費し、通常の定期タスクに影響を与える可能性があります。
指定エポック
選択したタスクが実行される期間。タスクは、そのスケジュール時刻がこの期間内にある場合にのみインスタンスを生成して実行します。これを使用して、時間単位または分単位の定期タスクの指定された期間のインスタンスのみを実行します。デフォルトは
00:00-23:59です。説明-
タスクのスケジュール時刻がこの期間内にない場合、タスクはインスタンスを生成しません。より大きなサイクルのタスクがより小さなサイクルのタスクに依存する場合 (たとえば、日次タスクが時間単位タスクに依存する場合)、孤立インスタンスが生成され、タスクの操作がブロックされる可能性があります。
-
このパラメーターは、時間単位または分単位の定期タスクが指定された期間のデータをバックフィルする必要がある場合にのみ変更することを推奨します。
グループ実行
複数のビジネス日付のデータをバックフィルする場合、同時実行に使用するグループの数を指定します。
-
はい:プラットフォームはビジネス日付を指定された数のグループに分割し、同時に実行します。
-
いいえ:ビジネス日付の順にシリアルに実行します。次のインスタンスは、前のインスタンスが完了した後にのみ実行されます。
説明時間単位または分単位のタスクの特定の日付のインスタンスがグループで同時に実行されるかどうかは、時間単位または分単位のタスク自体に自己依存が設定されているかどうかによって異なります。
グループの数は
2 から 10の範囲です。複数のインスタンスグループは次のように同時に実行されます。-
ビジネス日付の期間がグループ数より短い場合、タスクはグループで同時に実行されます。
たとえば、ビジネス日付が
1 月 11 日から 1 月 13 日で、グループ数が 4 の場合、3 つのデータバックフィルインスタンスのみが生成され (各データバックフィルインスタンスは 1 つのビジネス日付に対応)、3 つのインスタンスはグループで同時に実行されます。 -
業務日の期間がグループ数を超えた場合、プラットフォームは、業務日の 順序 に基づいて、タスクを直列および並列で実行します。
たとえば、ビジネス日付が
1 月 11 日から 1 月 13 日で、グループ数が 2 の場合、2 つのデータバックフィルインスタンスが生成され (データバックフィルインスタンスの 1 つには 2 つのビジネス日付が含まれ、これら 2 つのビジネス日付のタスクはシリアルに実行されます)、2 つのデータバックフィルインスタンスは並列で実行されます。
データバックフィルアラート
このデータバックフィルがアラートをトリガーするかどうかを指定します。
-
はい:トリガー条件が満たされるとアラートが生成されます。
-
いいえ:このデータバックフィルはアラートをトリガーしません。
トリガー条件
データバックフィルアラート が はい に設定されている場合にのみ使用できます。
-
失敗、成功のいずれの場合もアラート:データバックフィルが成功または失敗した場合にアラートが生成されます。
-
成功アラート:データバックフィルが成功した場合にのみアラートが生成されます。
-
失敗アラート:データバックフィルが失敗した場合にのみアラートが生成されます。
アラート方式
データバックフィルアラート が はい に設定されている場合にのみ使用できます。ショートメッセージとメール、ショートメッセージ、または メール でアラートを受信できます。アラートの受信者はデータバックフィルの開始者です。
説明連絡先の検証 をクリックして、アラート受信者の電話番号またはメールアドレスが登録されているかどうかを確認します。登録されていない場合は、「アラート連絡先の設定」をご参照ください。
順序
データバックフィルを データタイムスタンプ昇順 または データタイムスタンプ (降順) で実行するかを選択します。
リソースグループのスケジューリング
データバックフィルインスタンスの実行に使用されるリソースグループ。
-
タスクの設定に従う:定期タスクに設定されたリソースグループを使用します。
-
スケジューリングリソースグループの指定:データバックフィルと定期インスタンス間の競合を避けるために、指定されたリソースグループを使用します。
説明-
リソースグループのネットワーク接続が設定されていることを確認してください。そうでない場合、タスクが失敗する可能性があります。指定されたリソースグループが関連するワークスペースに関連付けられていない場合、元の定期タスクのリソースグループが引き続き使用されます。
-
サーバーレスリソースグループまたは専用スケジューリングリソースグループを使用することを推奨します。これにより、タスクが高い同時実行性で実行され、ずらした時間帯で実行できない場合に、高速で安定したデータ転送を保証するための専用の計算リソースグループを提供できます。
実行時間帯
データバックフィルタスクが実行される時間を指定します。
-
タスクの設定に従う:データバックフィルインスタンスのスケジュール時刻に基づいて実行します。
-
期間の指定:データバックフィルタスクを指定された期間内でのみ実行するように制限します。バックフィルするタスクの数に基づいてランタイム期間を設定します。
説明この期間後に未実行状態のタスクは実行されず、この期間後に実行中状態のタスクは引き続き実行されます。
計算リソース
現在、EMR および Serverless Spark 計算リソースのみがデータバックフィルの計算リソースとして設定できます。
マップされた計算リソースが存在し、利用可能であることを確認してください。そうでない場合、タスクのスケジューリングに影響が出る可能性があります。
-
-
-
データバックフィルタスクのチェックポリシーを設定します。
チェックが失敗した場合にタスクの実行を終了するかどうかを設定します。プラットフォームは、このデータバックフィルタスクの基本ステータスと潜在的なリスクをチェックします。
-
コミット をクリックして、データバックフィルタスクの作成を完了します。
ステップ 3: データバックフィルタスクの実行
データバックフィルタスクが設定されたランタイムに達し、異常がない場合、自動的にトリガーされます。
次の場合、タスクは実行できません。
-
チェックが有効になっており、チェックの失敗により実行がブロックされている場合。詳細については、「データバックフィルタスクの作成: ステップ 4」をご参照ください。
-
拡張チェックが有効になっており、チェックの失敗により実行がブロックされている場合。詳細については、「拡張機能の管理」をご参照ください。
データバックフィルインスタンスの管理
データバックフィルインスタンスのクエリ
左側のナビゲーションウィンドウで、 をクリックして、データバックフィルページに移動します。
データバックフィルページの右側で、検索の展開 をクリックして、データ補完名、実行状態、タスクタイプ などの条件でクエリするインスタンスをフィルターします。実行中のデータバックフィルタスクをバッチで迅速に終了することもできます。
データバックフィルインスタンスのステータスの表示
データバックフィルインスタンスに関する情報を表示します。これには以下が含まれます。
-
タスク名:データバックフィルインスタンスの名前を表示します。インスタンス名の前にある
アイコンをクリックすると、インスタンスの実行日と実行ステータス、およびそれに含まれるノードとその実行詳細が表示されます。 -
ステータスのチェック:現在のデータバックフィルインスタンスのチェックステータス。
-
実行状態:成功、失敗、リソース待機中、トリガー待機中などのステータスが含まれます。異常なステータスに基づいて関連する問題をトラブルシューティングできます。
-
ノード数:データバックフィルインスタンスに含まれるノードの数。
-
データタイムスタンプ:データバックフィルインスタンスが実行される日付。
-
最大並列インスタンス数:タスクに設定された最大並列インスタンス数を表示します。[無制限] または特定の値 (1 から 10000) です。この設定は、同時に実行できる同じタスクの最大インスタンス数を制限します。この値は、定期インスタンス、データバックフィルインスタンス、およびテストインスタンス間で共有されます。
-
タスク分析結果 を表示します:期待されるインスタンス、実行日、およびリスクチェック結果を表示して、ブロックされたタスクを迅速に処理します。ページには、データバックフィル名、タスク分析 (ワークスペース名と期待されるインスタンス数)、ビジネス日付の範囲、指定された期間の時間範囲、およびリスクチェックの結果 (サイクル検出と孤立タスク検出を含む) が表示されます。
-
操作:データバックフィルインスタンスに対して、バッチ終了、バッチ再実行、再利用などの操作を実行できます。
操作
説明
バッチ終了
データバックフィルインスタンス内の 実行中 状態のインスタンスを選択してバッチ終了できます。この操作後、対応するインスタンスは 実行失敗 状態に設定されます。
説明停止済み、実行が完了しました。、または 実行失敗 状態のインスタンスの終了はサポートされていません。
バッチ再実行
データバックフィルインスタンスをバッチで再実行します。
説明-
実行が完了しました。 または 実行失敗 状態のインスタンスのみ再実行できます。
-
バッチ再実行は、選択したインスタンスをすぐに再実行し、インスタンス間の依存関係に従って実行しません。順序通りに実行するには、ダウンストリームの再実行 を使用するか、データバックフィル 操作を再度実行してください。
再利用
以前のデータバックフィルのノードセットを再利用して、ノードを迅速に選択します。
-
データバックフィルタスクの管理
データバックフィルインスタンス内のノードに関する情報を表示します。これには以下が含まれます。
-
名前:ノード名をクリックすると、ノード詳細ページに移動し、より多くのノード情報を表示できます。
-
実行時刻:ノードタスクに設定されたスケジュールされたランタイム。
-
実行開始時刻:ノードタスクの実行開始時間。
-
終了時間:ノードタスクの実行終了時間。
-
実行時間:ノードタスクの実行期間。
-
操作:DAG グラフ の表示、実行の終了、再実行 などの操作でデータバックフィルノードタスクを管理できます。
操作
説明
DAG グラフ
ノードの DAG を表示して、ノードの上流および下流タスクを分析します。詳細については、「DAG 機能の概要」をご参照ください。
実行の終了
実行中 状態のノードを終了できます。この操作後、ノードは 実行失敗 状態に設定されます。
説明-
停止済み、実行が完了しました。、または 実行失敗 状態のノードの終了はサポートされていません。
-
この操作はインスタンスを失敗させ、その下流ノードをブロックします。注意して実行してください。
再実行
ターゲットノードタスクを再実行します。
説明成功または失敗状態のノードのみ再実行できます。
詳細
ダウンストリームの再実行
ターゲットノードタスクの下流ノードを再実行します。
設定が完了しました。
ノードタスクのステータスを成功に設定します。
[一時停止 (フリーズ)]
現在のノードを一時停止 (フリーズ) 状態に設定し、スケジューリングを停止します。
説明リソース待機中、待機時間、および 実行中 (ノードコード実行中、データ品質チェック進行中) 状態ではフリーズ操作はサポートされていません。
復元 (解凍)
一時停止 (フリーズ) されたノードのスケジューリングを再開します。
データリネージの表示
ノードの系列グラフを表示します。
-
選択したタスクノードについて、実行の終了 または 再実行 をクリックして、選択したノードタスクをバッチで終了または再実行します。
インスタンスのステータスの説明
|
ステータスタイプ |
ステータスインジケーター |
|
成功状態 |
|
|
未実行状態 |
|
|
失敗状態 |
|
|
実行中状態 |
|
|
待機中状態 |
|
|
フリーズ状態 |
|





