diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java index dfd71fc..2e2ed3c 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java @@ -198,7 +198,7 @@ public class SecureBulkLoadEndpoint extends SecureBulkLoadService } Token userToken = null; - if (request.getFsToken().hasIdentifier() && request.getFsToken().hasPassword()) { + if (userProvider.isHadoopSecurityEnabled()) { userToken = new Token(request.getFsToken().getIdentifier().toByteArray(), request.getFsToken() .getPassword().toByteArray(), new Text(request.getFsToken().getKind()), new Text( request.getFsToken().getService()));