SYSTEM AND METHOD FOR SUPPORTING DATA GRID SNAPSHOT AND FEDERATION

• US 20160092540A1
• Filed: 09/25/2015
• Published: 03/31/2016
• Est. Priority Date: 09/25/2014
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: BIHANI, BALLAV, Oliver, Brian Keith, Liu, Chen
• Granted Patent: US 10,664,495 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/256 in federated or virtual databases
• CPC Class Codes: G06F 16/278 Data partitioning, e.g. horizontal or vertical partitioning

Abstract

A system and method can support federation replication in a distributed computing environment. The system can provide one or more federation replication channels between a plurality of members in a first cluster and a plurality of members in a second cluster. Furthermore, a replication request can be transmitted from a federation coordinator to the plurality of members in the first cluster, wherein each said member in the first cluster owns a set of partitions. Then, the aggregated data for each said partition in the first cluster can be sent to the plurality of members in the second cluster via said one or more federation replication channels. Additionally, using the second cluster, the system can take a persistent snapshot of information on the plurality of members in the first cluster while the first cluster is operational.

Claims

1. A method for supporting federation replication in a distributed computing environment, the method comprising:

providing one or more federation replication channels between a plurality of members in a first cluster and a plurality of members in a second cluster;

transmitting a replication request from a federation coordinator to the plurality of members in the first cluster, wherein each said member in the first cluster owns a set of partitions; and

sending aggregated data for every partition in the first cluster to the plurality of members in the second cluster via said one or more federation replication channels.

2. The method of claim 1, further comprising:

taking a snapshot for the plurality of members in the first cluster while the first cluster is operational.

3. The method of claim 1, further comprising:

taking a snapshot for the plurality of members in the first cluster while the first cluster is operational by suspending the second cluster after it receives the aggregated data from the first cluster and then performing a snapshot operation on the second cluster.

4. The method of claim 1, further comprising:

taking a snapshot for the plurality of members in the first cluster while the first cluster is operational by suspending the second cluster after it receives the aggregated data from the first cluster and then performing a snapshot operation on the second cluster; and

resuming the second cluster after completion of the snapshot operation and resynchronizing the second cluster with the first cluster.

5. The method of claim 1, further comprising:

intercepting the replication request from the federation coordinator on each of the plurality of members in the first cluster.

6. The method of claim 1, further comprising:

intercepting the replication request from the federation coordinator on each of the plurality of members in the first cluster and, in response, aggregating data on each of the plurality of members in the first cluster for the set of partitions owned by said each of the plurality of members in the first cluster.

7. The method of claim 1, further comprising:

initiating federation replication upon cold start up of said second cluster.

8. The method of claim 1, further comprising:

initiating federation replication upon detecting an initial connection event from said second cluster.

9. The method of claim 1, further comprising:

initiating federation replication in response to administrator input to a management console.

10. The method of claim 1, wherein the distributed computing environment is a distributed data grid.

11. A system for supporting federation replication in a distributed data grid, the system comprising:

a first cluster comprising a first plurality of server nodes operating on a first plurality of computer systems each comprising a microprocessor and a memory, wherein each of the first plurality of server nodes owns a set of partitions holding data; and

;

a second cluster comprising a second plurality of server nodes operating on a second plurality of computer systems each comprising a microprocessor and a memory;

one or more federation replication channels between the plurality of server nodes in the first cluster and the plurality of server in the second cluster;

a federation coordinator configure to send a replication request to the plurality of server nodes in the first cluster; and

wherein, each of said first plurality of server nodes is configured such that, in response to receiving the replication request, said each of said first plurality of server nodes sends aggregated data for every partition owned by said each of said first plurality of server nodes to one of the second plurality of server nodes in said second cluster via said one or more federation replication channels.

12. The system of claim 11, wherein:

said second cluster is configured to support taking a snapshot for the plurality of server nodes in the first cluster while the first cluster is operational.

13. The system of claim 11, wherein:

said second cluster is configured to support taking a snapshot for the plurality of server nodes in the first cluster while the first cluster is operational by suspending the second cluster after it receives the aggregated data from the first cluster and then performing a snapshot operation on the second cluster.

14. The system of claim 11, wherein:

said second cluster is configured to support taking a snapshot for the plurality of server nodes in the first cluster while the first cluster is operational by suspending the second cluster after it receives the aggregated data from the first cluster and then performing a snapshot operation on the second cluster;

said second cluster is configured to resume operation of the second cluster after completion of the snapshot operation; and

said second cluster is configured to resynchronize with the first cluster after resuming operation.

15. The system of claim 11, wherein:

each of said first plurality of server nodes is configured to intercept the replication request from the federation coordinator.

16. The system of claim 11, wherein:

each of said first plurality of server nodes is configured to intercept the replication request from the federation coordinator; and

in response to intercepting the replication request aggregate data for every partition owned by said each of said first plurality of server nodes.

17. The system of claim 11, wherein the system is configured to initiate federation replication upon cold start-up of said second cluster.

18. The system of claim 11, wherein the system is configured to initiate federation replication upon detecting an initial connection event from said second cluster.

19. The system of claim 11, wherein the system is configured to initiate federation replication in response to administrator input to a management console.

20. A non-transitory computer readable medium including instruction stored thereon for supporting federation replication in a distributed computing environment, which instructions, when executed, configure nodes in the distributed computing environment to perform steps comprising:

providing one or more federation replication channels between a plurality of members in a first cluster and a plurality of members in a second cluster;

transmitting a replication request from a federation coordinator to the plurality of members in the first cluster, wherein each said member in the first cluster owns a set of partitions; and

sending aggregated data for every partition in the first cluster to the plurality of members in the second cluster via said one or more federation replication channels.