diff --git a/jdbc/src/main/java/com/yahoo/ycsb/db/JdbcDBClient.java b/jdbc/src/main/java/com/yahoo/ycsb/db/JdbcDBClient.java index 1b9645fc28ad448ca1150f7f3574daae47484b9a..3cb157028c98506bf3d249dfda79f7ddf5f09eef 100644 --- a/jdbc/src/main/java/com/yahoo/ycsb/db/JdbcDBClient.java +++ b/jdbc/src/main/java/com/yahoo/ycsb/db/JdbcDBClient.java @@ -305,6 +305,8 @@ public class JdbcDBClient extends DB implements JdbcDBClientConstants { select.append(" WHERE "); select.append(PRIMARY_KEY); select.append(" >= ?"); + select.append(" ORDER BY "); + select.append(PRIMARY_KEY); select.append(" LIMIT ?;"); PreparedStatement scanStatement = getShardConnectionByKey(key).prepareStatement(select.toString()); if (this.jdbcFetchSize != null) scanStatement.setFetchSize(this.jdbcFetchSize);