|
@@ -372,7 +372,7 @@ public class TestBalancer {
|
|
* Test parse method in Balancer#Cli class with threshold value out of
|
|
* Test parse method in Balancer#Cli class with threshold value out of
|
|
* boundaries.
|
|
* boundaries.
|
|
*/
|
|
*/
|
|
- @Test
|
|
|
|
|
|
+ @Test(timeout=100000)
|
|
public void testBalancerCliParseWithThresholdOutOfBoundaries() {
|
|
public void testBalancerCliParseWithThresholdOutOfBoundaries() {
|
|
String parameters[] = new String[] { "-threshold", "0" };
|
|
String parameters[] = new String[] { "-threshold", "0" };
|
|
String reason = "IllegalArgumentException is expected when threshold value"
|
|
String reason = "IllegalArgumentException is expected when threshold value"
|
|
@@ -394,7 +394,7 @@ public class TestBalancer {
|
|
|
|
|
|
/** Test a cluster with even distribution,
|
|
/** Test a cluster with even distribution,
|
|
* then a new empty node is added to the cluster*/
|
|
* then a new empty node is added to the cluster*/
|
|
- @Test
|
|
|
|
|
|
+ @Test(timeout=100000)
|
|
public void testBalancer0() throws Exception {
|
|
public void testBalancer0() throws Exception {
|
|
testBalancer0Internal(new HdfsConfiguration());
|
|
testBalancer0Internal(new HdfsConfiguration());
|
|
}
|
|
}
|
|
@@ -406,7 +406,7 @@ public class TestBalancer {
|
|
}
|
|
}
|
|
|
|
|
|
/** Test unevenly distributed cluster */
|
|
/** Test unevenly distributed cluster */
|
|
- @Test
|
|
|
|
|
|
+ @Test(timeout=100000)
|
|
public void testBalancer1() throws Exception {
|
|
public void testBalancer1() throws Exception {
|
|
testBalancer1Internal(new HdfsConfiguration());
|
|
testBalancer1Internal(new HdfsConfiguration());
|
|
}
|
|
}
|
|
@@ -419,7 +419,7 @@ public class TestBalancer {
|
|
new String[] {RACK0, RACK1});
|
|
new String[] {RACK0, RACK1});
|
|
}
|
|
}
|
|
|
|
|
|
- @Test
|
|
|
|
|
|
+ @Test(timeout=100000)
|
|
public void testBalancer2() throws Exception {
|
|
public void testBalancer2() throws Exception {
|
|
testBalancer2Internal(new HdfsConfiguration());
|
|
testBalancer2Internal(new HdfsConfiguration());
|
|
}
|
|
}
|
|
@@ -467,8 +467,7 @@ public class TestBalancer {
|
|
/**
|
|
/**
|
|
* Test parse method in Balancer#Cli class with wrong number of params
|
|
* Test parse method in Balancer#Cli class with wrong number of params
|
|
*/
|
|
*/
|
|
-
|
|
|
|
- @Test
|
|
|
|
|
|
+ @Test(timeout=100000)
|
|
public void testBalancerCliParseWithWrongParams() {
|
|
public void testBalancerCliParseWithWrongParams() {
|
|
String parameters[] = new String[] { "-threshold" };
|
|
String parameters[] = new String[] { "-threshold" };
|
|
String reason =
|
|
String reason =
|