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

HBASE-4859 Correctly PreWarm HBCK ThreadPool 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1212701 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2011-12-10 00:40:01 +00:00
parent d855d71ba8
commit 2261fc23c9
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java
View File

@ -31,7 +31,7 @@ import java.util.Set;
import java.util.SortedSet;
import java.util.TreeMap;
import java.util.TreeSet;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
@ -88,7 +88,6 @@ public class HBaseFsck {
public static final long DEFAULT_TIME_LAG = 60000; // default value of 1 minute
public static final long DEFAULT_SLEEP_BEFORE_RERUN = 10000;
private static final int MAX_NUM_THREADS = 50; // #threads to contact regions
private static final long THREADS_KEEP_ALIVE_SECONDS = 60;
private static final Log LOG = LogFactory.getLog(HBaseFsck.class.getName());
@ -112,7 +111,6 @@ public class HBaseFsck {
// Empty regioninfo qualifiers in .META.
private Set<Result> emptyRegionInfoQualifiers = new HashSet<Result>();
private int numThreads = MAX_NUM_THREADS;
private HBaseAdmin admin;
ThreadPoolExecutor executor; // threads to retrieve data from regionservers
@ -128,10 +126,11 @@ public class HBaseFsck {
ZooKeeperConnectionException, IOException {
this.conf = conf;
numThreads = conf.getInt("hbasefsck.numthreads", numThreads);
executor = new ThreadPoolExecutor(0, numThreads,
int numThreads = conf.getInt("hbasefsck.numthreads", Integer.MAX_VALUE);
executor = new ThreadPoolExecutor(1, numThreads,
THREADS_KEEP_ALIVE_SECONDS, TimeUnit.SECONDS,
new LinkedBlockingQueue<Runnable>());
new SynchronousQueue<Runnable>());
executor.allowCoreThreadTimeOut(true);
}
public void connect() throws MasterNotRunningException,