[發(fā)明專利]一種Oozie工作流程中多前驅(qū)多后繼節(jié)點的處理方法

在審

• 申請?zhí)枺?/td>: 201910940924.2
• 申請日: 2019-09-30
• 公開（公告）號: CN110647402A
• 公開（公告）日: 2020-01-03
• 發(fā)明（設(shè)計）人: 張旭;趙志宏;周慶勇;王建華
• 申請（專利權(quán)）人: 浪潮軟件股份有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 37100 濟南信達(dá)專利事務(wù)所有限公司
• 代理人: 郗艷榮

1.一種Oozie工作流程中多前驅(qū)多后繼節(jié)點的處理方法，其特征在于，包括以下步驟：

第一步，在各主任務(wù)節(jié)點之后分別設(shè)置一個多后繼任務(wù)處理節(jié)點，各主任務(wù)節(jié)點的分任務(wù)節(jié)點均設(shè)置在多后繼任務(wù)處理節(jié)點后方；在結(jié)束節(jié)點之前設(shè)置多前驅(qū)任務(wù)處理節(jié)點，需合并的各分任務(wù)節(jié)點均連接到同一個多前驅(qū)任務(wù)處理節(jié)點；

第二步，當(dāng)主任務(wù)節(jié)點完成之后，通過多后繼任務(wù)處理節(jié)點觸發(fā)啟動主任務(wù)節(jié)點的所有分任務(wù)節(jié)點，從而保證所有的分任務(wù)節(jié)點全部啟動執(zhí)行；

第三步，當(dāng)連接到同一個多前驅(qū)任務(wù)處理節(jié)點的分任務(wù)節(jié)點全部執(zhí)行完成之后，多前驅(qū)任務(wù)處理節(jié)點才會觸發(fā)結(jié)束節(jié)點，從而保證所有的分任務(wù)節(jié)點全部執(zhí)行之后才會結(jié)束工作流程。

2.根據(jù)權(quán)利要求1所述的Oozie工作流程中多前驅(qū)多后繼節(jié)點的處理方法，其特征在于：所述第二步中，多后繼任務(wù)處理節(jié)點將接入的所有分任務(wù)節(jié)點加入處理隊列中，當(dāng)Oozie的DAG檢測到當(dāng)前運行的工作節(jié)點是分任務(wù)節(jié)點時，自動啟動處理隊列中的分任務(wù)節(jié)點，并將已啟動的分任務(wù)節(jié)點從處理隊列中刪除；當(dāng)處理隊列中的所有的分任務(wù)節(jié)點都執(zhí)行完成之后，多后繼任務(wù)處理節(jié)點任務(wù)完成。

3.根據(jù)權(quán)利要求1所述的Oozie工作流程中多前驅(qū)多后繼節(jié)點的處理方法，其特征在于：所述第三步中，所述多前驅(qū)任務(wù)處理節(jié)點內(nèi)部設(shè)有計數(shù)器，計數(shù)器用于統(tǒng)計未執(zhí)行的分任務(wù)節(jié)點的數(shù)量；當(dāng)計數(shù)器計數(shù)為0時，表示分任務(wù)節(jié)點全部執(zhí)行完成，多前驅(qū)任務(wù)處理節(jié)點觸發(fā)結(jié)束節(jié)點，Oozie工作流程結(jié)束。

4.根據(jù)權(quán)利要求3所述的Oozie工作流程中多前驅(qū)多后繼節(jié)點的處理方法，其特征在于：所述分任務(wù)節(jié)點執(zhí)行完畢后，則刪除該分任務(wù)節(jié)點連接到多前驅(qū)任務(wù)處理節(jié)點的接入路徑，所述多前驅(qū)任務(wù)處理節(jié)點無法獲取該分任務(wù)節(jié)點的信息，計數(shù)器減1。

5.根據(jù)權(quán)利要求1～4任意一項所述的Oozie工作流程中多前驅(qū)多后繼節(jié)點的處理方法，其特征在于：所述多前驅(qū)任務(wù)處理節(jié)點和多后繼任務(wù)處理節(jié)點均采用輕量的代碼侵入方式設(shè)置，能夠兼容Oozie原有功能，保證原有的Oozie工作流程正常執(zhí)行。

6.根據(jù)權(quán)利要求5所述的Oozie工作流程中多前驅(qū)多后繼節(jié)點的處理方法，其特征在于：在Oozie的oozie-core項目定義MultiNextNodeDef和MultiPrevNodeDef，所述MultiNextNodeDef即為多后繼任務(wù)處理節(jié)點，所述MultiPrevNodeDef即為多前驅(qū)任務(wù)處理節(jié)點。

7.根據(jù)權(quán)利要求6所述的Oozie工作流程中多前驅(qū)多后繼節(jié)點的處理方法，其特征在于：在所述MultiNextNodeDef中定義執(zhí)行器為MultiNextActionExecutor和內(nèi)部類SingalXCommand，所述SingalXCommand用于將新開始的分任務(wù)節(jié)點加入處理隊列中，并實時監(jiān)測分任務(wù)節(jié)點的執(zhí)行情況，將已經(jīng)完成的分任務(wù)節(jié)點從處理隊列中刪除。

8.根據(jù)權(quán)利要求6所述的Oozie工作流程中多前驅(qū)多后繼節(jié)點的處理方法，其特征在于：在所述MultiPrevNodeDef中定義執(zhí)行器MultiPrevActionExecutor，用于獲取未執(zhí)行的尾端任務(wù)節(jié)點的數(shù)量N，并賦值給計數(shù)器。