diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java index b84f9a2..c2f22ec 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java +++ 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(); }