From ae45b996a3127b3d50023b7293fe24355a1474c6 Mon Sep 17 00:00:00 2001 From: Esteban Gutierrez Date: Mon, 8 Dec 2014 22:13:31 -0800 Subject: [PATCH] HBASE-11979 Compaction progress reporting is wrong --- .../apache/hadoop/hbase/regionserver/compactions/Compactor.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java index 2ddc06a..4b62cad 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java @@ -126,10 +126,10 @@ public abstract class Compactor { LOG.warn("Null reader for " + file.getPath()); continue; } - // NOTE: getFilterEntries could cause under-sized blooms if the user - // switches bloom type (e.g. from ROW to ROWCOL) - long keyCount = (r.getBloomFilterType() == store.getFamily().getBloomFilterType()) - ? r.getFilterEntries() : r.getEntries(); + // NOTE: use getEntries when compacting instead of getFilterEntries, otherwise under-sized + // blooms can cause progress to be miscalculated or if the user switches bloom + // type (e.g. from ROW to ROWCOL) + long keyCount = r.getEntries(); fd.maxKeyCount += keyCount; // calculate the latest MVCC readpoint in any of the involved store files Map fileInfo = r.loadFileInfo(); -- 1.8.4