Method and system for resolving data inconsistency
First Claim
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.
9 Assignments
0 Petitions
Accused Products
Abstract
Method, system, and programs for resolving data inconsistency in a distributed system having a plurality of replica instances. In response to a read request of at least one data element, a key-specific probability value for the at least one data element of the read request is retrieved. Based on the retrieved key-specific probability value and a system load of the distributed system, a self-healing probability of the at least one data element of the read request is computed. A self-healing transaction that includes the at least one data element of the read request is then generated based on the self-healing probability of the at least one data element. The generated self-healing transaction is further applied to at least some of the plurality of replica instances in the distributed system to resolve data inconsistency.
32 Citations
22 Claims
-
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. - View Dependent Claims (2, 3, 4, 5, 6, 7, 22)
-
-
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. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
-
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. - View Dependent Claims (16, 17, 18, 19, 20, 21)
-
Specification