diff --git a/spring-batch-core-tests/src/test/java/org/springframework/batch/core/test/football/FootballJobIntegrationTests.java b/spring-batch-core-tests/src/test/java/org/springframework/batch/core/test/football/FootballJobIntegrationTests.java index 61bb5847f..8b1a72a38 100644 --- a/spring-batch-core-tests/src/test/java/org/springframework/batch/core/test/football/FootballJobIntegrationTests.java +++ b/spring-batch-core-tests/src/test/java/org/springframework/batch/core/test/football/FootballJobIntegrationTests.java @@ -73,6 +73,11 @@ public class FootballJobIntegrationTests { assertEquals(BatchStatus.COMPLETED, execution.getStatus()); for (StepExecution stepExecution : execution.getStepExecutions()) { logger.info("Processed: " + stepExecution); + if (stepExecution.getStepName().equals("playerload")) { + // The effect of the retries + assertEquals(new Double(Math.ceil(stepExecution.getReadCount() / 10. + 1)).intValue(), + stepExecution.getCommitCount()); + } } } diff --git a/spring-batch-core-tests/src/test/java/org/springframework/batch/core/test/football/FootballJobSkipIntegrationTests.java b/spring-batch-core-tests/src/test/java/org/springframework/batch/core/test/football/FootballJobSkipIntegrationTests.java index b4da01443..ac3f3501e 100644 --- a/spring-batch-core-tests/src/test/java/org/springframework/batch/core/test/football/FootballJobSkipIntegrationTests.java +++ b/spring-batch-core-tests/src/test/java/org/springframework/batch/core/test/football/FootballJobSkipIntegrationTests.java @@ -94,6 +94,11 @@ public class FootballJobSkipIntegrationTests { assertEquals(BatchStatus.COMPLETED, execution.getStatus()); for (StepExecution stepExecution : execution.getStepExecutions()) { logger.info("Processed: " + stepExecution); + if (stepExecution.getStepName().equals("playerload")) { + // The effect of the retries + assertEquals(stepExecution.getReadCount()*2, stepExecution.getRollbackCount()); + assertEquals(stepExecution.getReadCount(), stepExecution.getWriteSkipCount()); + } } }