IN PROGRESS - issue BATCH-495: readers must not clear buffers on mark()
http://jira.springframework.org/browse/BATCH-495 moved the initial itemHandler.mark() out of the loop
This commit is contained in:
@@ -267,6 +267,7 @@ public class ItemOrientedStep extends AbstractStep {
|
||||
// reference to the ExecutionContext as the step execution.
|
||||
listener.beforeStep(stepExecution);
|
||||
stream.open(stepExecution.getExecutionContext());
|
||||
itemHandler.mark();
|
||||
|
||||
status = stepOperations.iterate(new RepeatCallback() {
|
||||
|
||||
@@ -287,7 +288,6 @@ public class ItemOrientedStep extends AbstractStep {
|
||||
|
||||
try {
|
||||
|
||||
itemHandler.mark();
|
||||
result = processChunk(stepExecution, contribution);
|
||||
contribution.incrementCommitCount();
|
||||
|
||||
|
||||
Reference in New Issue
Block a user