Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

BATCH-1616: changed semantics of PartitionNameProvider to revert to old (2.1.0) behaviour on restart

Browse Source
This commit is contained in:
dsyer
2010-08-13 08:26:47 +00:00
parent 8fe407b379
commit 926fcf9ac0
1 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
spring-batch-core/src/main/java/org/springframework/batch/core/partition/support/SimpleStepExecutionSplitter.java
View File

@@ -191,22 +191,21 @@ public class SimpleStepExecutionSplitter implements StepExecutionSplitter, Initi
result = partitioner.partition(splitSize);
}
else {
/*
* We need to return the same keys as the original (failed)
* execution, but the execution contexts will be discarded so they
* can be empty.
*/
if (partitioner instanceof PartitionNameProvider) {
result = new HashMap<String, ExecutionContext>();
Collection<String> names = ((PartitionNameProvider) partitioner).getPartitionNames(splitSize);
for (String name : names) {
/*
* We need to return the same keys as the original (failed)
* execution, but the execution contexts will be discarded
* so they can be empty.
*/
result.put(name, new ExecutionContext());
}
}
else {
// If no names are provided, assume they follow the default
// pattern.
result = new SimplePartitioner().partition(splitSize);
// If no names are provided, grab the partition again.
result = partitioner.partition(splitSize);
}
}