US 11,886,284 B2
System and method for data redistribution in a database
Le Cai, Cupertino, CA (US); QingQing Zhou, Santa Clara, CA (US); and Yang Sun, Palo Alto, CA (US)
Assigned to Futurewei Technologies, Inc., Addison, TX (US)
Filed by Futurewei Technologies, Inc., Addison, TX (US)
Filed on May 17, 2022, as Appl. No. 17/746,841.
Application 17/746,841 is a continuation of application No. 16/737,534, filed on Jan. 8, 2020, granted, now 11,334,422, issued on May 17, 2022.
Application 16/737,534 is a continuation of application No. 15/227,546, filed on Aug. 3, 2016, granted, now 10,545,815, issued on Jan. 28, 2020.
Prior Publication US 2022/0276922 A1, Sep. 1, 2022
Int. Cl. G06F 11/07 (2006.01); G06F 16/11 (2019.01); G06F 16/25 (2019.01); G06F 16/27 (2019.01); G06F 11/14 (2006.01)
CPC G06F 11/0793 (2013.01) [G06F 11/079 (2013.01); G06F 11/0709 (2013.01); G06F 11/0751 (2013.01); G06F 11/0787 (2013.01); G06F 11/1451 (2013.01); G06F 11/1464 (2013.01); G06F 11/1469 (2013.01); G06F 16/128 (2019.01); G06F 16/258 (2019.01); G06F 16/27 (2019.01); G06F 2201/80 (2013.01); G06F 2201/84 (2013.01)] 20 Claims
OG exemplary drawing
 
1. A method for data redistribution of job data in a source data node (DN) to at least one destination DN in a Massively Parallel Processing (MPP) Database (DB), the method comprising:
recording a snapshot of the job data, the snapshot including job data information;
splitting the job data of the source DN into a plurality of data portions, the data portions comprising a first data portion in the source DN and a second data portion in the source DN, and the snapshot comprising information about the split of the job data;
collecting job data copy changes;
identifying one or more first changes to the first data portion and identifying one or more second changes to the second data portion from the collected changes and based on the snapshot;
initiating transfer of the second data portion from the source DN to the at least one destination DN;
determining the data transfer of the second data portion to the at least one destination DN has failed;
merging the identified one or more first changes into the first data portion in the source DN; and
merging the identified one or more second changes into the second data portion in the source DN based on the failure of the data transfer of the second data portion to the at least one destination DN.