Index: src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java (revision 1081040) +++ src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java (working copy) @@ -115,9 +115,10 @@ connection = admin.getConnection(); 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); } /**