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 index b84f9a2..c2f22ec 100644 --- 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 @@ -1851,7 +1851,7 @@ public class RSRpcServices implements HBaseRPCErrorHandler, if (request.hasCloseScanner()) { closeScanner = request.getCloseScanner(); } - int rows = 1; + int rows = closeScanner ? 0 : 1; if (request.hasNumberOfRows()) { rows = request.getNumberOfRows(); }