@@ -2043,17 +2043,17 @@ public void abort() throws IOException {
20432043
20442044  @ Override 
20452045  public  boolean  needsCompaction () {
2046-     //For some system compacting, we set selectNow to false, and the files do not 
2047-     //be selected until compaction runs, so we should limit the compaction count here 
2048-     //to avoid the length of queue grows too big. 
2049-     int  filesNotCompacting  = this .storeEngine .storeFileManager .getStorefileCount ()
2050-       - filesCompacting .size ();
2051-     int  maxFilesToCompact  = this .storeEngine .getCompactionPolicy ().getConf ()
2052-       .getMaxFilesToCompact ();
2046+     // For some system compacting, we set selectNow to false, and the files do not 
2047+     // be selected until compaction runs, so we should limit the compaction count here 
2048+     // to avoid the length of queue grows too big. 
2049+     int  filesNotCompacting  =
2050+       this .storeEngine .storeFileManager .getStorefileCount () - filesCompacting .size ();
2051+     int  maxFilesToCompact  = this .storeEngine .getCompactionPolicy ().getConf ().getMaxFilesToCompact ();
20532052    int  maxCompactionsShouldBeQueued  = filesNotCompacting  / maxFilesToCompact ;
20542053    maxCompactionsShouldBeQueued  += filesNotCompacting  % maxFilesToCompact  == 0  ? 0  : 1 ;
20552054    if  (this .compactionsQueuedCount .sum () >= maxCompactionsShouldBeQueued ) {
2056-       LOG .debug ("this store has too many compactions in queue, filesNotCompacting:{}, " 
2055+       LOG .debug (
2056+         "this store has too many compactions in queue, filesNotCompacting:{}, " 
20572057          + "compactionsQueuedCount:{}, maxCompactionsNeedQueued:{}" ,
20582058        filesNotCompacting , this .compactionsQueuedCount .sum (), maxCompactionsShouldBeQueued );
20592059      return  false ;
0 commit comments