diff --git a/qa/sql/src/main/java/org/elasticsearch/xpack/qa/sql/jdbc/SpecBaseIntegrationTestCase.java b/qa/sql/src/main/java/org/elasticsearch/xpack/qa/sql/jdbc/SpecBaseIntegrationTestCase.java index 8fd8aa8395a..f155286e27f 100644 --- a/qa/sql/src/main/java/org/elasticsearch/xpack/qa/sql/jdbc/SpecBaseIntegrationTestCase.java +++ b/qa/sql/src/main/java/org/elasticsearch/xpack/qa/sql/jdbc/SpecBaseIntegrationTestCase.java @@ -91,9 +91,7 @@ public abstract class SpecBaseIntegrationTestCase extends JdbcIntegrationTestCas protected ResultSet executeJdbcQuery(Connection con, String query) throws SQLException { Statement statement = con.createStatement(); - //statement.setFetchSize(randomInt(10)); - // NOCOMMIT: hook up pagination - statement.setFetchSize(1000); + statement.setFetchSize(between(1, 500)); return statement.executeQuery(query); }