PERFORMING CONFLICT ANALYSIS OF REPLICATED CHANGES AMONG NODES IN A NETWORK

• US 20170228411A1
• Filed: 02/09/2016
• Published: 08/10/2017
• Est. Priority Date: 02/09/2016
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Cadarette, Paul M., Spyker, James D.
• Granted Patent: US 10,540,340 B2
• Time in Patent Office: Days
• CPC Class Codes: G06F 16/122 using management policies backup systems G06F11/1446; file migration policies for HSM systems G06F16/185
• CPC Class Codes: G06F 16/2315 Optimistic concurrency control
• CPC Class Codes: G06F 16/235 Update request formulation
• CPC Class Codes: G06F 16/2365 Ensuring data consistency and integrity
• CPC Class Codes: G06F 16/2379 Updates performed during online database operations; commit processing
• CPC Class Codes: G06F 16/273 Asynchronous replication or reconciliation
• CPC Class Codes: G06F 16/275 Synchronous replication
• CPC Class Codes: H04L 67/1095 Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes

Abstract

Provided are a computer program product, system, and method for performing conflict analysis of replicated changes among nodes in a network A first node and a second node include a first instance and second instance of a data set, respectively. The second node receives a first transaction replicated from the first node, applied to the first instance of the data set. The second node determines a conflict that would occur between the replicated first transaction and a second transaction applied to the second instance of the data set. A conflict policy is applied at the second node to perform a first action in response to determining the conflict. The conflict policy is applied to the first node to perform a second action at the first node to handle the conflict when the first node receives a replication of the second transaction to the second instance of the data set.

Claims

1. A computer program product for determining conflicts of changes updating instances of a data set at different nodes in a network including a first node and a second node, wherein each of the nodes includes one instance of the data set, the computer program product comprising a computer readable storage medium having computer readable program code embodied therein that executes to perform operations, the operations comprising:

receiving at the second node having a second instance of the data set a first transaction replicated from the first node, wherein the first transaction was applied to a first instance of the data set of the first node;

determining, at the second node, a conflict that would occur between the replicated first transaction and a second transaction applied to the second instance of the data set; and

applying a conflict policy at the second node to perform a first action in response to determining the conflict, wherein the conflict policy is applied to the first node to perform a second action at the first node to handle the conflict when the first node receives a replication of the second transaction to the second instance of the data set at the second node.

2. The computer program product of claim 1, wherein the first and second actions apply the first and second transactions to the second and first nodes, respectively, and notify an initiator of the first and second transactions resulting in the conflict.

3. The computer program product of claim 1, wherein the first node maintains a first update log of transactions applied to the first instance of the data set and the second node maintains a second update log of transactions applied to the second instance of the data set, wherein the second node determines the conflict by determining whether the first transaction conflicts with the second transaction indicated in the second update log.

4. The computer program product of claim 1, wherein the determining the conflict comprises determining whether application of the first transaction to the second instance of the data set would result in a satisfying a condition, wherein the conflict policy specifies an additional action to perform in response to determining that application of the first transaction would result in the satisfying the condition.

5. The computer program product of claim 4, wherein the satisfying the condition indicates an error introduced by the application of the first transaction to the second instance of the data set, wherein the first action specifies to correct the error in the second data set resulting from the application of the first transaction.

6. The computer program product of claim 4, wherein the first and second instances of the data set comprises a database, and wherein the satisfying the condition comprises a record in the first and/or second instance of the data set having at least one of a key not found error, column mismatch, row mismatch, and wherein the first and the second actions perform an operation on the record including the error at the second and first data sets, respectively, to correct the error.

7. The computer program product of claim 4, wherein the first and second actions of the conflict policy specify to allow the first and second transactions that result in the satisfying the conflict to be applied to the second and first instances of the data set, respectively, and wherein the first and second actions take corrective action that does not alter the first and second transactions made to the second and first data sets, respectively.

8. The computer program product of claim 1, wherein a plurality of intervening transactions are made to the second instance of the data set, including the second transaction, between a time of receiving the first transaction and a previous replicated transaction from the first node applied to the second instance of the data set received at the second node before the first transaction, wherein the operations further comprise:

determining whether the first transaction conflicts with the plurality of intervening transactions at the first instance of the data set.

9. The computer program product of claim 1, wherein the applying the conflict policy comprises:

applying the first transaction to a first record in the second instance of the data set; and

modifying a second record in the second instance of the data set based on content of the first record resulting from applying the first transaction.

10. A system in communication with a first node in a network having a first instance of a data set, comprising:

a storage device having a second instance of the data set;

a second node, including;

a processor;

a computer readable storage medium including computer readable program code executed by the processor to perform operations, the operations comprising;

receiving a first transaction replicated from the first node, wherein the first transaction was applied to a first instance of the data set of the first node;

determining a conflict that would occur between the replicated first transaction and a second transaction applied to the second instance of the data set; and

applying a conflict policy at the second node to perform a first action in response to determining the conflict, wherein the conflict policy is applied to the remote node to perform a second action at the first node to handle the conflict when the first node receives a replication of the second transaction to the second instance of the data set.

11. The system of claim 10, wherein the first and second actions apply the first and second transactions to the second and first nodes, respectively, and notify an initiator of the first and second transactions resulting in the conflict.

12. The system of claim 10, wherein the first node maintains a first update log of transactions applied to the first instance of the data set and the second node maintains a second update log of transactions applied to the second instance of the data set, wherein the second node determines the conflict by determining whether the first transaction conflicts with the second transaction indicated in the second update log.

13. The system of claim 10, wherein the determining the conflict comprises determining whether application of the first transaction to the second instance of the data set would result in a satisfying a condition, wherein the conflict policy specifies an additional action to perform in response to determining that application of the first transaction would result in the satisfying the condition.

14. The system of claim 10, wherein a plurality of intervening transactions are made to the second instance of the data set, including the second transaction, between a time of receiving the first transaction and a previous replicated transaction from the first node applied to the second instance of the data set received at the second node before the first transaction, wherein the operations further comprise:

determining whether the first transaction conflicts with the plurality of intervening transactions at the first instance of the data set.

15. The system of claim 10, wherein the applying the conflict policy comprises:

applying the first transaction to a first record in the second instance of the data set; and

modifying a second record in the second instance of the data set based on content of the first record resulting from applying the first transaction.

21. The system of claim 13, wherein the satisfying the condition indicates an error introduced by the application of the first transaction to the second instance of the data set, wherein the first action specifies to correct the error in the second data set resulting from the application of the first transaction.

22. The system of claim 13, wherein the first and second instances of the data set comprises a database, and wherein the satisfying the condition comprises a record in the first and/or second instance of the data set having at least one of a key not found error, column mismatch, row mismatch, and wherein the first and the second actions perform an operation on the record including the error at the second and first data sets, respectively, to correct the error.

23. The system of claim 13, wherein the first and second actions of the conflict policy specify to allow the first and second transactions that result in the satisfying the conflict to be applied to the second and first instances of the data set, respectively, and wherein the first and second actions take corrective action that does not alter the first and second transactions made to the second and first data sets, respectively.

16-20. -20. (canceled)