diff --git src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java index b5e7015..0e010a2 100644 --- src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java +++ src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java @@ -129,9 +129,10 @@ public class HBaseFsck { this.conf = conf; numThreads = conf.getInt("hbasefsck.numthreads", numThreads); - executor = new ThreadPoolExecutor(0, numThreads, + executor = new ThreadPoolExecutor(numThreads, numThreads, THREADS_KEEP_ALIVE_SECONDS, TimeUnit.SECONDS, new LinkedBlockingQueue()); + executor.allowCoreThreadTimeOut(true); } public void connect() throws MasterNotRunningException,