diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/RegionServerRpcQuotaManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/RegionServerRpcQuotaManager.java index 69253d7..d44ea56 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/RegionServerRpcQuotaManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/RegionServerRpcQuotaManager.java @@ -176,7 +176,13 @@ public class RegionServerRpcQuotaManager { private OperationQuota checkQuota(final Region region, final int numWrites, final int numReads, final int numScans) throws IOException, ThrottlingException { - UserGroupInformation ugi = RpcServer.getRequestUser().orElse(User.getCurrent()).getUGI(); + User user = RpcServer.getRequestUser().get(); + UserGroupInformation ugi; + if (user != null) { + ugi = user.getUGI(); + } else { + ugi = User.getCurrent().getUGI(); + } TableName table = region.getTableDescriptor().getTableName(); OperationQuota quota = getQuota(ugi, table);