BATCH-1396: added assertions to integration test
This commit is contained in:
@@ -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());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -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());
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user