0003713: Extract row count statistics double when staging is cleared

JumpMind · Sep 10, 2018 · 0443de5 · 0443de5
1 parent a000d14
commit 0443de5
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/model/AbstractBatch.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/model/AbstractBatch.java
@@ -188,6 +188,13 @@ public void revertStatsOnError() {
         }
     }
 
+    public void resetExtractRowStats() {
+        this.extractRowCount = 0;
+        this.extractInsertRowCount = 0;
+        this.extractUpdateRowCount = 0;
+        this.extractDeleteRowCount = 0;
+    }
+
     public long getBatchId() {
         return batchId;
     }

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
@@ -2159,6 +2159,7 @@ public SelectFromSymDataSource(OutgoingBatch outgoingBatch,
                     sourceNode.getNodeId(), outgoingBatch.getNodeId(), outgoingBatch.isCommonFlag());
             this.targetNode = targetNode;
             this.columnsAccordingToTriggerHistory = new ColumnsAccordingToTriggerHistory(sourceNode, targetNode);
+            this.outgoingBatch.resetExtractRowStats();
         }
 
         public Batch getBatch() {
@@ -2420,6 +2421,7 @@ public SelectFromTableSource(OutgoingBatch outgoingBatch, Batch batch,
             List<SelectFromTableEvent> initialLoadEvents = new ArrayList<DataExtractorService.SelectFromTableEvent>(
                     1);
             initialLoadEvents.add(event);
+            this.outgoingBatch.resetExtractRowStats();
             this.init(batch, initialLoadEvents);
         }