0002843: When a common batch is sent to more than one target, subsequent

target nodes are sent a retry instead of the batch data
JumpMind · Oct 3, 2016 · 76748ce · 76748ce
1 parent a73eeb7
commit 76748ce
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -959,7 +959,7 @@ protected boolean isPreviouslyExtracted(OutgoingBatch currentBatch) {
     protected boolean isRetry(OutgoingBatch currentBatch, Node remoteNode) {
         IStagedResource previouslyExtracted = getStagedResource(currentBatch);
         return previouslyExtracted != null && previouslyExtracted.exists() && previouslyExtracted.getState() != State.CREATE
-                && currentBatch.getStatus() != OutgoingBatch.Status.RS && remoteNode.isVersionGreaterThanOrEqualTo(3, 8, 0);
+                && currentBatch.getStatus() != OutgoingBatch.Status.RS && currentBatch.getSentCount() > 0 && remoteNode.isVersionGreaterThanOrEqualTo(3, 8, 0);
     }
 
     protected OutgoingBatch sendOutgoingBatch(ProcessInfo processInfo, Node targetNode,