Index: security/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java =================================================================== --- security/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java (revision 1559803) +++ security/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java (working copy) @@ -150,7 +150,7 @@ @Override public boolean bulkLoadHFiles(final List> familyPaths, - final Token userToken, final String bulkToken) throws IOException { + final Token userToken, final String bulkToken, boolean assignSeqId) throws IOException { User user = getActiveUser(); final UserGroupInformation ugi = user.getUGI(); if(userToken != null) { @@ -188,7 +188,7 @@ //We call bulkLoadHFiles as requesting user //To enable access prior to staging return env.getRegion().bulkLoadHFiles(familyPaths, - new SecureBulkLoadListener(fs, bulkToken)); + new SecureBulkLoadListener(fs, bulkToken), assignSeqId); } catch (Exception e) { LOG.error("Failed to complete bulk load", e); } Index: security/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadProtocol.java =================================================================== --- security/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadProtocol.java (revision 1559803) +++ security/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadProtocol.java (working copy) @@ -58,10 +58,11 @@ * @param familyPaths column family to HFile path pairs * @param userToken requesting user's HDFS delegation token * @param bulkToken + * @parem assignSeqId * @return * @throws IOException */ - boolean bulkLoadHFiles(List> familyPaths, - Token userToken, String bulkToken) throws IOException; + boolean bulkLoadHFiles(List> familyPaths, Token userToken, + String bulkToken, boolean assignSeqId) throws IOException; }