Method and system for resolving data inconsistency

1. A method, implemented on at least one machine each having at least one processor, storage, and a communication platform connected to a network for resolving data inconsistency in a distributed system having a plurality of replica instances, comprising:

in response to a read request of at least one data element, retrieving, by a probability assigning module, a first probability associated with the at least one data element of the read request;

computing, by the probability assigning module, a second probability associated with the at least one data element of the read request based on a write throughput of the distributed system and the retrieved first probability;

generating, by a transaction generating module, a transaction associated with the at least one data element of the read request based on the second probability associated with the at least one data element; and

applying, by a transaction dispatcher via a data replication bus, the generated transaction to at least some of the plurality of replica instances in the distributed system to resolve data inconsistency across the at least some of the plurality of replica instances.

2. The method of claim 1 , wherein

the second probability associated with a data element increases as the write throughput of the distributed system decreases.

3. The method of claim 1 , wherein

the first probability associated with a data element is provided based on a transaction history of the data element;

the second probability associated with a data element decreases when a transaction associated with the data element has been applied; and

the second probability associated with a data element increases when the data element has been updated.

4. The method of claim 1 further comprising determining, by a policy checking module, whether the transaction is to be applied based on one or more predetermined rules.

5. The method of claim 4 , wherein the step of determining whether the transaction is to be applied comprises:

determining whether a write transaction has been requested, wherein the write transaction is associated with the same at least one data element in the transaction; and

discarding the transaction if the write transaction has been requested.

6. The method of claim 1 , wherein

the at least one data element in the transaction includes a key, a value, and a time stamp indicating when the value of the at least one data element was most recently updated; and

the step of applying the generated transaction comprises:

comparing the time stamp of the at least one data element associated with the transaction with a time stamp of a corresponding data element in each replica instance,

if the time stamp of the at least one data element associated with the transaction is more recent than a time stamp of a corresponding data element in a replica instance, replacing a value of the corresponding data element in the replica instance with the value of the at least one data element associated with the transaction, and

if the time stamp of the at least one data element associated with the transaction is not more recent than the time stamp of a corresponding data element in a replica instance, discarding the transaction in the corresponding replica instance.

7. The method of claim 1 , wherein

the transaction is an writing operation on at least one data element of at least some of the plurality of replica instances in response to a read request by a user or an application; and

the transaction includes directive information that controls an application thereof to each of the some replica instances in the distributed system.

8. A system for resolving data inconsistency in a distributed system having a plurality of replica instances, comprising:

a probability assigning module configured to

in response to a read request of at least one data element, retrieve a first probability associated with the at least one data element of the read request, and

compute a second probability associated with the at least one data element of the read request based on a write throughput of the distributed system and the retrieved first probability;

a transaction generating module operatively coupled to the probability assigning module, configured to generate a transaction associated with the at least one data element of the read request based on the second probability associated with the at least one data element; and

a transaction dispatcher operatively coupled to the transaction generating module, configured to apply, via a data replication bus, the generated transaction to at least some of the plurality of replica instances in the distributed system to resolve data inconsistency across the at least some of the plurality of replica instances.

9. The system of claim 8 , wherein

the second probability associated with a data element increases as the write throughput of the distributed system decreases.

10. The system of claim 8 , wherein

the first probability associated with a data element is provided based on a transaction history of the data element;

the second probability associated with a data element decreases when a transaction associated with the data element has been applied; and

the second probability associated with a data element increases when the data element has been updated.

11. The system of claim 8 further comprising a policy checking module operatively coupled to the transaction generating module and the transaction dispatcher, configured to determine whether the transaction is to be applied based on one or more predetermined rules.

12. The system of claim 11 , wherein the policy checking module, in determining whether a self-healing transaction is to be generated, is further configured to:

determine whether a write transaction has been requested, wherein the write transaction is associated with the same at least one data element in the transaction; and

discard the transaction if the write transaction has been requested.

13. The system of claim 8 , wherein

the at least one data element in the transaction includes a key, a value, and a time stamp indicating when the value of the at least one data element was most recently updated; and

the step of applying the generated transaction comprises:

comparing the time stamp of the at least one data element associated with the transaction with a time stamp of a corresponding data element in each replica instance,

if the time stamp of the at least one data element associated with the transaction is more recent than a time stamp of a corresponding data element in a replica instance, replacing a value of the corresponding data element in the replica instance with the value of the at least one data element associated with the transaction, and

if the time stamp of the at least one data element associated with the transaction is not more recent than the time stamp of a corresponding data element in a replica instance, discarding the transaction in the corresponding replica instance.

14. The system of claim 8 , wherein

the transaction is an writing operation on at least one data element of at least some of the plurality of replica instances in response to a read request by a user or an application; and

the transaction includes directive information that controls an application thereof to each of the some replica instances in the distributed system.

15. A machine-readable tangible and non-transitory medium having information recorded thereon for resolving data inconsistency in a distributed system having a plurality of replica instances, wherein the information, when read by the machine, causes the machine to perform the following:

in response to a read request of at least one data element, retrieving a first probability associated with the at least one data element of the read request;

computing a second probability associated with the at least one data element of the read request based on a write throughput of the distributed system and the retrieved first probability;

generating a transaction associated with the at least one data element of the read request based on the second probability associated with the at least one data element; and

applying the generated transaction to at least some of the plurality of replica instances in the distributed system to resolve data inconsistency across the at least some of the plurality of replica instances.

16. The medium of claim 15 , wherein

the second probability associated with a data element increases as the write throughput of the distributed system decreases.

17. The medium of claim 15 , wherein

the first probability associated with a data element is provided based on a transaction history of the data element;

the second probability associated with a data element decreases when a transaction associated with the data element has been applied; and

the second probability associated with a data element increases when the data element has been updated.

18. The medium of claim 15 further comprising determining whether the transaction is to be applied based on one or more predetermined rules.

19. The medium of claim 15 , wherein the step of determining whether the self-healing transaction is to be applied comprises:

determining whether a write transaction has been requested, wherein the write transaction is associated with the same at least one data element in the transaction; and

discarding the transaction if the write transaction has been requested.

20. The medium of claim 15 , wherein

the at least one data element in the transaction includes a key, a value, and a time stamp indicating when the value of the at least one data element was most recently updated; and

the step of applying the generated transaction comprises:

comparing the time stamp of the at least one data element associated with the transaction with a time stamp of a corresponding data element in each replica instance,

if the time stamp of the at least one data element associated with the transaction is more recent than a time stamp of a corresponding data element in a replica instance, replacing a value of the corresponding data element in the replica instance with the value of the at least one data element associated with the transaction, and

if the time stamp of the at least one data element associated with the transaction is not more recent than the time stamp of a corresponding data element in a replica instance, discarding the transaction in the corresponding replica instance.

21. The medium of claim 15 , wherein

the transaction is an writing operation on at least one data element of at least some of the plurality of replica instances in response to a read request by a user or an application; and

the transaction includes directive information that controls an application thereof to each of the some replica instances in the distributed system.

22. The method of claim 1 , wherein the second probability is computed by multiplying the first probability and a scaling factor determined based on the write throughput of the distribution system.