[發明專利]使用復制的任務結果管理計算集群

在審

• 申請號: 201880071520.8
• 申請日: 2018-10-30
• 公開（公告）號: CN111316241A
• 公開（公告）日: 2020-06-19
• 發明（設計）人: 克雷格·W·斯坦菲爾;約瑟夫·S·沃利三世
• 申請（專利權）人: 起元技術有限責任公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/54
• 代理公司: 北京林達劉知識產權代理事務所(普通合伙) 11277
• 代理人: 劉新宇

1.一種用于在包括多個處理節點的分布式數據處理系統中處理任務的方法，該方法包括：

使用該多個處理節點中的兩個或更多個處理節點來處理多個任務集，每個任務集被配置用于生成相應的結果集，并與多個時間間隔中的相應時間間隔相關聯，

在該多個處理節點中的第一處理節點處維護多個計數器，該多個計數器包括：

工作計數器，該工作計數器在該分布式數據處理系統中指示該多個時間間隔中的當前時間間隔，以及

復制計數器，該復制計數器指示該多個時間間隔中的某個時間間隔，在該時間間隔內，在該多個處理節點中的數個處理節點處復制以下中的至少一個：(1)與該時間間隔相關聯的所有任務以及(2)與該時間間隔相關聯的所有相應結果，以及

從該第一處理節點向該多個處理節點中的其他處理節點提供消息，該消息包括該工作計數器和該復制計數器。

2.如權利要求1所述的方法，其中，該處理包括：在該多個處理節點中的主要處理節點處執行與至少一些任務相關聯的計算，以及在該多個處理節點中的一個或多個備用處理節點處執行與該至少一些任務的復制品相關聯的計算。

3.如權利要求1或2所述的方法，其中，在該主要處理節點處執行與第一任務相關聯的計算包括在該主要處理節點處生成第一結果，并且在該備用處理節點處執行與該第一任務的復制品相關聯的計算包括在該備用處理節點處生成該第一結果。

4.如權利要求1至3中任一項所述的方法，其中，在該主要處理節點處執行的與該第一任務相關聯的計算和在該備用處理節點處執行的與該第一任務的復制品相關聯的計算這兩者都在提交操作之后開始，該提交操作指示該第一任務和該第一任務的復制品已被持久地存儲。

5.如權利要求1至3中任一項所述的方法，其中，該第一結果包括已在該主要處理節點和該備用處理節點處復制的原始數據的修改后的版本。

6.如權利要求1至3中任一項所述的方法，其中，在該主要處理節點處執行的與該第一任務相關聯的計算同在該備用處理節點處執行的與該第一任務的復制品相關聯的計算相同。

7.如權利要求6所述的方法，其中，在該主要處理節點處執行的與該第一任務相關聯的計算和在該備用處理節點處執行的與該第一任務的復制品相關聯的計算是確定性的，并且不依賴于該數個處理節點中的哪一個來執行這些計算。

8.如權利要求2所述的方法，其中，該復制計數器指示該多個時間間隔中的某個時間間隔，在該時間間隔內，在該多個處理節點中的數個處理節點處復制與該時間間隔相關聯的所有任務以及與該時間間隔相關聯的所有相應結果。

9.如權利要求1至8中任一項所述的方法，其中，該處理包括：在該多個處理節點中的主要處理節點處執行與至少一些任務相關聯的計算，而該任務的復制品在備用處理節點處保持休眠；以及從該主要處理節點向該備用處理節點發送與執行了計算的任務相對應的結果。

10.如權利要求9所述的方法，其中，在該主要處理節點處執行的與該第一任務相關聯的計算包括生成第一結果，并且在該第一任務已在該主要處理節點處完成之后從該主要處理節點向該備用處理節點發送該第一結果。

11.如權利要求9或10所述的方法，其中，該第一結果包括已在該主要處理節點和該備用處理節點處復制的原始數據的修改后的版本。

12.如權利要求9所述的方法，其中，該復制計數器指示該多個時間間隔中的某個時間間隔，在該時間間隔內，在該多個處理節點中的數個處理節點處復制與該時間間隔相關聯的所有任務以及與該時間間隔相關聯的所有相應結果。