diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index 0fcdaab..19bcd33 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -1823,7 +1823,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi // We no longer need to cancel the request on the way out of this // method because Store#compact will clean up unconditionally requestNeedsCancellation = false; - store.compact(compaction, throughputController); + store.compact(compaction, throughputController, user); } catch (InterruptedIOException iioe) { String msg = "compaction interrupted"; LOG.info(msg, iioe);