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 a5a48f3..3c79e56 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 @@ -294,7 +294,7 @@ public abstract class Compactor { try { /* Include deletes, unless we are doing a major compaction */ ScanType scanType = scannerFactory.getScanType(request); - scanner = preCreateCoprocScanner(request, scanType, fd.earliestPutTs, scanners); + scanner = preCreateCoprocScanner(request, scanType, fd.earliestPutTs, scanners, user); if (scanner == null) { scanner = scannerFactory.createScanner(scanners, scanType, fd, smallestReadPoint); } @@ -344,14 +344,10 @@ public abstract class Compactor { * @param scanType Scan type. * @param earliestPutTs Earliest put ts. * @param scanners File scanners for compaction files. + * @param user the User * @return Scanner override by coprocessor; null if not overriding. */ protected InternalScanner preCreateCoprocScanner(final CompactionRequest request, - ScanType scanType, long earliestPutTs, List scanners) throws IOException { - return preCreateCoprocScanner(request, scanType, earliestPutTs, scanners, null); - } - - protected InternalScanner preCreateCoprocScanner(final CompactionRequest request, final ScanType scanType, final long earliestPutTs, final List scanners, User user) throws IOException { if (store.getCoprocessorHost() == null) {