diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SecureBulkLoadManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SecureBulkLoadManager.java index e8a9154d41..51ff712bdc 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SecureBulkLoadManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SecureBulkLoadManager.java @@ -45,6 +45,7 @@ import org.apache.hadoop.hbase.security.UserProvider; import org.apache.hadoop.hbase.security.token.AuthenticationTokenIdentifier; import org.apache.hadoop.hbase.security.token.ClientTokenUtil; import org.apache.hadoop.hbase.security.token.FsDelegationToken; +import org.apache.hadoop.hbase.tool.BulkLoadHFiles; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.CommonFSUtils; import org.apache.hadoop.hbase.util.FSUtils; @@ -113,6 +114,9 @@ public class SecureBulkLoadManager { private ConcurrentHashMap ugiReferenceCounter; private AsyncConnection conn; + private static final String ASSIGN_SEQ_IDS = BulkLoadHFiles.ASSIGN_SEQ_IDS; + private boolean assignSeqIds; + SecureBulkLoadManager(Configuration conf, AsyncConnection conn) { this.conf = conf; this.conn = conn; @@ -124,6 +128,7 @@ public class SecureBulkLoadManager { ugiReferenceCounter = new ConcurrentHashMap<>(); fs = FileSystem.get(conf); baseStagingDir = new Path(CommonFSUtils.getRootDir(conf), HConstants.BULKLOAD_STAGING_DIR_NAME); + assignSeqIds = conf.getBoolean(ASSIGN_SEQ_IDS, true); if (conf.get("hbase.bulkload.staging.dir") != null) { LOG.warn("hbase.bulkload.staging.dir " + " is deprecated. Bulkload staging directory is " @@ -286,7 +291,7 @@ public class SecureBulkLoadManager { } //We call bulkLoadHFiles as requesting user //To enable access prior to staging - return region.bulkLoadHFiles(familyPaths, true, + return region.bulkLoadHFiles(familyPaths, assignSeqIds, new SecureBulkLoadListener(fs, bulkToken, conf), request.getCopyFile(), clusterIds, request.getReplicate()); } catch (Exception e) {