Permalink
Browse files

Updated test AbstractRebalanceTest.java

  • Loading branch information...
1 parent 8f54d38 commit b61a24581f148ea1a3d4026bc3d9ebc057252e59 Chinmay Soman committed Aug 8, 2011
Showing with 10 additions and 8 deletions.
  1. +10 −8 test/unit/voldemort/client/rebalance/AbstractRebalanceTest.java
View
18 test/unit/voldemort/client/rebalance/AbstractRebalanceTest.java
@@ -234,7 +234,7 @@ public void checkConsistentMetadata(Cluster targetCluster, List<Integer> serverL
}
}
- // @Test
+ @Test
public void testRORWRebalance() throws Exception {
Cluster currentCluster = ServerTestUtils.getLocalCluster(2, new int[][] {
{ 0, 1, 2, 3, 4, 5, 6, 7, 8 }, {} });
@@ -283,7 +283,7 @@ public void testRORWRebalance() throws Exception {
}
}
- // @Test
+ @Test
public void testRORWRebalanceWithReplication() throws Exception {
Cluster currentCluster = ServerTestUtils.getLocalCluster(2, new int[][] {
{ 0, 1, 2, 3, 4, 5, 6 }, { 7, 8 } });
@@ -328,7 +328,7 @@ public void testRORWRebalanceWithReplication() throws Exception {
}
}
- // @Test
+ @Test
public void testRORebalanceWithReplication() throws Exception {
Cluster currentCluster = ServerTestUtils.getLocalCluster(2, new int[][] {
{ 0, 1, 2, 3, 4, 5, 6 }, { 7, 8 } });
@@ -370,7 +370,7 @@ public void testRORebalanceWithReplication() throws Exception {
}
}
- // @Test
+ @Test
public void testRWRebalanceWithReplication() throws Exception {
Cluster currentCluster = ServerTestUtils.getLocalCluster(2, new int[][] {
{ 0, 1, 2, 3, 4, 5, 6 }, { 7, 8 } });
@@ -412,7 +412,7 @@ public void testRWRebalanceWithReplication() throws Exception {
}
}
- // @Test
+ @Test
public void testRebalanceCleanPrimary() throws Exception {
Cluster currentCluster = ServerTestUtils.getLocalCluster(3, new int[][] { { 0 }, { 1, 3 },
{ 2 } });
@@ -524,11 +524,13 @@ public void testRebalanceCleanSecondary() throws Exception {
Lists.newArrayList(3));
// start servers 0 , 1, 2
+ Map<String, String> configProps = new HashMap<String, String>();
+ configProps.put("enable.repair", "true");
List<Integer> serverList = Arrays.asList(0, 1, 2);
currentCluster = startServers(currentCluster,
rwStoreDefFileWithReplication,
serverList,
- null);
+ configProps);
// Update the cluster information based on the node information
targetCluster = updateCluster(targetCluster);
@@ -614,7 +616,7 @@ public void testRebalanceCleanSecondary() throws Exception {
}
}
- // @Test
+ @Test
public void testProxyGetDuringRebalancing() throws Exception {
final Cluster currentCluster = ServerTestUtils.getLocalCluster(2, new int[][] {
{ 0, 1, 2, 3, 4, 5, 6 }, { 7, 8 } });
@@ -751,7 +753,7 @@ public void run() {
}
}
- // @Test
+ @Test
public void testServerSideRouting() throws Exception {
final Cluster currentCluster = ServerTestUtils.getLocalCluster(2, new int[][] {
{ 0, 1, 2, 3, 4, 5, 6 }, { 7, 8 } });

0 comments on commit b61a245

Please sign in to comment.