fix warnings

apache · Jan 26, 2024 · dd7adca · dd7adca
1 parent 31a7882
commit dd7adca
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java
@@ -3653,7 +3653,9 @@ public ScanResponse scan(final RpcController controller, final ScanRequest reque
       }
 
       quota.addScanResult(results);
-      quota.addBlockBytesScanned(rpcCall.getBlockBytesScanned());
+      if (rpcCall != null) {
+        quota.addBlockBytesScanned(rpcCall.getBlockBytesScanned());
+      }
       addResults(builder, results, (HBaseRpcController) controller,
         RegionReplicaUtil.isDefaultReplica(region.getRegionInfo()),
         isClientCellBlockSupport(rpcCall));

diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestBlockBytesScannedQuota.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestBlockBytesScannedQuota.java
@@ -195,9 +195,9 @@ public void testBBSMultiGet() throws Exception {
     assertEquals(100, doMultiGets(100, 10, rowCount, FAMILY, QUALIFIER, table));
     assertEquals(100, doMultiGets(100, 10, rowCount, FAMILY, QUALIFIER, table));
 
-    // Add 100 block/min limit
+    // Add ~100 block/min limit
     admin.setQuota(QuotaSettingsFactory.throttleUser(userName, ThrottleType.REQUEST_SIZE,
-      Math.round(100 * blockSize), TimeUnit.MINUTES));
+      Math.round(100.1 * blockSize), TimeUnit.MINUTES));
     triggerUserCacheRefresh(TEST_UTIL, false, TABLE_NAME);
 
     // should execute approximately 10 batches of 10 requests