From 76748ce76d6721083ed839de5da1a6bac657d446 Mon Sep 17 00:00:00 2001 From: Chris Henson Date: Mon, 3 Oct 2016 10:42:54 -0400 Subject: [PATCH] 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/symmetric/service/impl/DataExtractorService.java | 2 +- 1 file changed, 1 insertion(+), 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 index c2e694cbba..433a93a071 100644 --- 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,