diff --git a/service/pager/query_pagers.cc b/service/pager/query_pagers.cc
index 9dcf00da56..bafbcd62aa 100644
--- a/service/pager/query_pagers.cc
+++ b/service/pager/query_pagers.cc
@@ -279,7 +279,7 @@ private:
             }
         };
 
-        myvisitor v(*this, page_size, builder, *_schema, *_selection);
+        myvisitor v(*this, std::min(page_size, _max), builder, *_schema, *_selection);
         query::result_view::consume(results->buf(), _cmd->slice, v);
 
         _max = _max - v.included_rows;