0004489: Node host channel stats sent count inflated

JumpMind · Jul 30, 2020 · d64b8d8 · d64b8d8
1 parent a6a19e3
commit d64b8d8
Showing 1 changed file with 4 additions and 2 deletions.
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
@@ -1402,8 +1402,10 @@ protected OutgoingBatch sendOutgoingBatch(ProcessInfo processInfo, Node targetNo
 
                                     targetResource.setState(State.DONE);
                                     isRetry = true;
-                                    statisticManager.incrementDataSent(currentBatch.getChannelId(), currentBatch.getDataRowCount());
-                                    statisticManager.incrementDataBytesSent(currentBatch.getChannelId(), extractedBatch.getFile().length());
+                                    if (currentBatch.getSentCount() == 1) {
+                                        statisticManager.incrementDataSent(currentBatch.getChannelId(), currentBatch.getDataRowCount());
+                                        statisticManager.incrementDataBytesSent(currentBatch.getChannelId(), extractedBatch.getFile().length());
+                                    }
                                 } catch (Exception e) {   
                                     FileUtils.deleteQuietly(targetResource.getFile());
                                     throw new RuntimeException(e);