全部產品
Search
文件中心

Dataphin:管理已提交執行個體

更新時間:May 29, 2025

已提交執行個體是對周期任務發起立即運行補資料操作或待提交執行個體產生的可運行執行個體。您可以對已提交執行個體執行重跑、終止、置為成功繼續調度、暫停或恢複等操作。本文為您介紹如何查看並管理已提交執行個體。

已提交執行個體入口

  1. 在Dataphin首頁的頂部功能表列,選擇研發 > 任務營運

  2. 在左側導覽列中選擇執行個體營運 > 補資料執行個體

  3. 在頂部功能表列選擇生產或開發環境。

  4. 補資料執行個體頁面,單擊已提交執行個體頁簽。

已提交執行個體頁面介紹

已提交執行個體頁面主要由搜尋及篩選區域、篩選區域、已提交執行個體列表、大量操作區組成。您可以在已提交執行個體頁面對產生的補資料執行個體進行相關的營運操作。

image

區塊

描述

篩選及功能區

通過輸入執行個體對象名稱或ID來篩選已提交執行個體,適用於知曉執行個體對象ID或名稱時進行篩選出所需的已提交執行個體。

  • 我提交的:選中後篩選出提交人為當前操作帳號對應的已提交執行個體。

  • 補數失敗:選中後篩選出提交人為當前操作帳號對應的補資料狀態為失敗的已提交執行個體。

  • 補數未完成:選中後篩選出提交人為當前操作帳號對應的補資料狀態為運行中或未完成的已提交執行個體。

  • 篩選:單擊篩選,展開篩選區域。如果需要重新篩選,則可單擊重設,即可快速清空所有篩選條件,恢複系統預設。支援篩選項包括:

    • 執行個體運行狀態:可以根據已提交執行個體的運行狀態進行篩選,篩選符合對應狀態的執行個體。支援7種執行個體的運行狀態篩選,包括成功、失敗、運行中、未運行、等待調度資源、等待調度時間、限流中七種執行個體的運行狀態。

    • 補資料狀態:可以根據已提交執行個體的補資料狀態進行篩選。補資料狀態包括成功失敗未運行運行中。更多資訊,請參見補資料執行個體狀態說明

    • 執行個體負責人:可以根據已提交執行個體的負責人進行篩選。

    • 補資料提交人:可以根據已提交執行個體的提交人進行篩選。

    • 業務日期:預設為全部的已提交執行個體,支援選擇今天昨天一定日期範圍內的已提交執行個體。

    • 開始已耗用時間:預設為當天開始啟動並執行已提交執行個體,支援選擇今天昨天某一天的開始啟動並執行已提交執行個體。

    • 提交日期:提交日期支援篩選今天昨天全部,或某一天提交的已提交執行個體。

    • 專案:根據任務所在專案進行篩選,可選擇多個當前登入使用者擁有營運-訪問目錄許可權的專案。

      說明

      使用專案篩選後,列表中僅展示補資料工作流程下選定專案的執行個體。

    • 調度資源群組:可根據執行個體指定的運行時使用的調度資源群組進行篩選

  • 重新整理:單擊image重新整理按鈕,系統將重新整理當前周期執行個體列表

已提交執行個體列表

已提交執行個體頁面以列表形式為您展示周期任務產生的已提交執行個體,包括補資料名稱-業務日期補資料狀態補資料任務提交人/時間業務日期運行時間長度節點數及支援的操作。更多資訊,請參見查看已提交執行個體列表

大量操作區

您可通過大量操作地區提供的大量操作功能,批量對補資料執行個體進行批量處理,提高操作效率。具體說明,請參見已提交執行個體支援的大量操作

補資料執行個體狀態說明

系統根據業務日期運行狀態定義補資料執行個體的運行狀態。整個補資料執行個體的運行狀態,根據所有業務日期的歸一狀態判斷,判斷邏輯如下表。

補資料執行個體存在暫停執行個體時,補資料狀態除展示歸一狀態外,也將展示當前補資料下是否存在暫停執行個體,存在部分暫停執行個體則展示為部分暫停,所有執行個體均為暫停則展示為全部暫停

判斷順序

歸一狀態

判斷邏輯

1

未運行

初始化或所有執行個體狀態均為未運行,則補資料執行個體的狀態為未運行。

2

運行中

存在等待中或運行中的執行個體且沒有運行失敗的執行個體,則補資料執行個體的狀態為運行中。

3

失敗

存在失敗的執行個體,則補資料執行個體的狀態即為失敗。

4

成功

所有執行個體狀態均為成功,則補資料執行個體的狀態即為成功。

查看已提交執行個體列表

補資料執行個體營運列表頁面展示當前補資料名稱-業務日期補資料狀態補資料任務提交人/時間業務日期運行時間長度節點數及支援的操作。

已提交執行個體的單個已提交執行個體包括三層,如下圖所示。

image.png

區塊

說明

第一層

補資料任務層:即補資料任務,名稱為執行補資料操作時配置的執行個體名稱。每提交一次補資料操作產生對應一個補資料任務層。

第二層

業務日期層:展示補資料執行個體下所有需要補資料的業務日期,每個業務日期對應一個檔案夾。

第三層

補資料執行個體層:展示對任務執行補資料操作後產生的執行個體,同時您也可以查看該執行個體依賴的DAG圖。每個業務日期下包含的補資料執行個體的DAG相同。

  • 第一層、第二層:單個補資料執行個體的支援的操作。

    操作

    描述

    一鍵終止

    Dataphin自動選中當前檔案夾下運行狀態為等待中運行中的節點、狀態為未運行運行中等待中的邏輯表欄位及其連帶欄位執行終止操作。同時對其他運行狀態的節點或邏輯表欄位無影響。

    一鍵重跑失敗執行個體

    Dataphin自動選中當前檔案夾下運行狀態為失敗的節點或邏輯表欄位進行重跑。同時對其他運行狀態的節點或邏輯表欄位無影響。

  • 第三層:單個補資料執行個體支援的操作。

    說明
    • 單擊資料執行個體運行狀態欄的image按鈕,可根據運行狀態快速篩選執行個體。運行狀態包括:成功、失敗、運行中、等待調度時間、限流中、未運行、等待調度資源。

    • 單擊執行個體名稱欄的image按鈕,可搜尋當前補資料任務中的補資料執行個體。

    • 單擊補資料執行個體定時已耗用時間結束已耗用時間運行時間長度欄的image.png表徵圖,支援按照定時已耗用時間結束已耗用時間運行時間長度進行升序降序排序。

    整合和計算任務以及建模任務對補資料執行個體支援的操作與對應的周期執行個體支援的操作相同。更多資訊,請參見:

已提交執行個體支援的大量操作

已提交執行個體支援的大量操作和周期執行個體支援的大量操作不同。已提交執行個體的大量操作詳情見下表。

操作

描述

重跑

選中多個補資料執行個體後,在列表底部選擇重跑所有失敗執行個體重跑所有終態執行個體強制重跑所有執行個體。重跑後,直接更新當前執行個體節點的資料。因當前執行個體運行失敗而未開始啟動並執行下遊節點,在當前執行個體重跑成功後,會自動開始運行。

  • 重跑所有失敗執行個體:重跑運行狀態為失敗的節點。

  • 重跑所有終態執行個體:重跑運行狀態為失敗成功的節點。

  • 強制重跑所有執行個體:除邏輯表模型發生過變更的邏輯表執行個體外,其他所有狀態的節點或欄位均可強制重跑。

終止

成功未運行的執行個體不支援終止,其他狀態執行個體均支援進行終止操作。終止後執行個體的運行狀態變更為失敗。當前執行個體節點終止運行後,該節點的下遊節點也不會運行。

說明

選中的執行個體中包括成功未運行狀態的執行個體,不支援批量終止操作。

終止操作多用於如下情境:

  • 由於Dataphin異常或操作失誤,需要終止執行個體。

  • 執行個體顯示運行中,但資料一直未產出。可以手動終止運行並通過作業記錄排查異常。

置成功繼續調度

同時將多個運行失敗未運行的執行個體節點手動置運行成功,繼續參與調度。下遊僅因當前執行個體失敗而被阻斷啟動並執行執行個體將開始運行。

重要

依賴當前執行個體運行產生資料的下遊執行個體可能會運行錯誤,請您評估風險。

暫停

未運行等待調度時間限流中的執行個體支援暫停。

說明

暫停時只對支援暫停執行個體生效,系統將自動跳過不支援暫停執行個體。

恢複

僅暫停執行個體支援恢複。

說明

恢複時只對支援暫停執行個體生效,系統將自動跳過不支援恢複的執行個體。

修改優先順序

單擊image表徵圖,選擇修改優先順序,在批量修改優先順序對話方塊中修改所選中任務的優先順序,可選擇最高最低

補資料DAG節點支援的操作

單擊補資料執行個體名稱,進入補資料DAG圖。DAG圖展示每個業務日期下補資料節點及其依賴節點間的關係。

Dataphin支援跨專案節點的營運管理。對跨專案的補資料執行個體節點進行營運操作時,需要具備執行個體所在專案的查看及操作許可權。

說明

查看DAG圖時,執行個體對象列表將展示執行個體對象的名稱和定時已耗用時間。滑鼠指標至執行個體對象,將展示當前對象的節點名、節點ID、定時已耗用時間、運行時間長度。

補資料DAG節點支援的操作與周期執行個體支援的操作相同,詳情請參見: