diff --git a/spring-batch-samples/src/test/java/org/springframework/batch/sample/iosample/JdbcPagingRestartIntegrationTests.java b/spring-batch-samples/src/test/java/org/springframework/batch/sample/iosample/JdbcPagingRestartIntegrationTests.java index 11019d9bb..062a90d0b 100644 --- a/spring-batch-samples/src/test/java/org/springframework/batch/sample/iosample/JdbcPagingRestartIntegrationTests.java +++ b/spring-batch-samples/src/test/java/org/springframework/batch/sample/iosample/JdbcPagingRestartIntegrationTests.java @@ -68,7 +68,8 @@ public class JdbcPagingRestartIntegrationTests { ExecutionContext executionContext = new ExecutionContext(); int count = SimpleJdbcTestUtils.countRowsInTable(jdbcTemplate, "CUSTOMER")-2; executionContext.putInt("JdbcPagingItemReader.read.count", count); - executionContext.putInt("JdbcPagingItemReader.start.after", 2); + // Assume the primary keys are in order + executionContext.putInt("JdbcPagingItemReader.start.after", count); ((ItemStream)reader).open(executionContext); CustomerCredit item = reader.read(); // System.err.println(item);