HBASE-27676 Scan handlers in the RPC executor should match at least o…

…ne scan queues
apache · Mar 2, 2023 · c2349db · c2349db
1 parent d2b0074
commit c2349db
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java
@@ -79,10 +79,11 @@ public RWQueueRpcExecutor(final String name, final int handlerCount, final int m
     int readQueues = calcNumReaders(this.numCallQueues, callqReadShare);
     int readHandlers = Math.max(readQueues, calcNumReaders(handlerCount, callqReadShare));
 
-    int scanQueues = Math.max(0, (int) Math.floor(readQueues * callqScanShare));
     int scanHandlers = Math.max(0, (int) Math.floor(readHandlers * callqScanShare));
+    int scanQueues =
+      scanHandlers > 0 ? Math.max(1, (int) Math.floor(readQueues * callqScanShare)) : 0;
 
-    if ((readQueues - scanQueues) > 0) {
+    if (scanQueues > 0) {
       readQueues -= scanQueues;
       readHandlers -= scanHandlers;
     } else {