HBASE-13528 A bug on selecting compaction pool (Shuaifeng Zhou)

This commit is contained in:
tedyu 2015-04-24 02:16:41 -07:00
parent ad2b1d8467
commit e1cb405adc
1 changed files with 1 additions and 2 deletions

View File

@ -346,8 +346,7 @@ public class CompactSplitThread implements CompactionRequestor, PropagatingConfi
// We assume that most compactions are small. So, put system compactions into small
// pool; we will do selection there, and move to large pool if necessary.
long size = selectNow ? compaction.getRequest().getSize() : 0;
ThreadPoolExecutor pool = (!selectNow && s.throttleCompaction(size))
ThreadPoolExecutor pool = (selectNow && s.throttleCompaction(compaction.getRequest().getSize()))
? longCompactions : shortCompactions;
pool.execute(new CompactionRunner(s, r, compaction, pool));
if (LOG.isDebugEnabled()) {