Added double check that all partition data has been processed before ending

2013-12-16 12:59:30 -06:00
parent b5d48df0cf
commit ee30259612
1 changed files with 1 additions and 1 deletions
--- a/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/partition/JsrPartitionHandler.java
+++ b/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/partition/JsrPartitionHandler.java
@@ -178,7 +178,7 @@ public class JsrPartitionHandler implements PartitionHandler, InitializingBean {

 			processFinishedPartitions(tasks, result);

-			if(tasks.size() == 0) {
+			if(tasks.size() == 0 && partitionDataQueue.isEmpty()) {
 				break;
 			}
 		}