Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

If waiting on a balance, after each unsuccessful attempt, call balancer in case it hasn't been run (Fail on hudson of build #1532 looks to be a postponed balance and then wait on a balance that would never come 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1021385 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2010-10-11 15:30:58 +00:00
parent 50430b219c
commit 999cb8af7c
2 changed files with 18 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/main/java/org/apache/hadoop/hbase/client/HTable.java
View File

@ -19,6 +19,23 @@
*/
package org.apache.hadoop.hbase.client;
import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration;
@ -38,25 +55,6 @@ import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.Pair;
import org.apache.hadoop.hbase.util.Writables;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.Executors;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.io.DataInput;
import java.io.DataOutput;
/**
* Used to communicate with a single HBase table.
*

1
src/test/java/org/apache/hadoop/hbase/TestRegionRebalancing.java
View File

@ -192,6 +192,7 @@ public class TestRegionRebalancing extends HBaseClusterTestCase {
Thread.sleep(10000);
} catch (InterruptedException e) {}
cluster.getMaster().balance();
continue;
}