fix extract start time and row counts

JumpMind · Feb 26, 2019 · 1c7aff2 · 1c7aff2
1 parent 199662f
commit 1c7aff2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...etric-core/src/main/java/org/jumpmind/symmetric/service/impl/MultiBatchStagingWriter.java b/...etric-core/src/main/java/org/jumpmind/symmetric/service/impl/MultiBatchStagingWriter.java
@@ -220,6 +220,8 @@ public void checkSend(Statistics stats) {
 
         if (!batchFromDatabase.getStatus().equals(Status.OK) && !batchFromDatabase.getStatus().equals(Status.IG)) {
             this.outgoingBatch.setStatus(Status.NE);
+            this.outgoingBatch.setExtractRowCount(this.outgoingBatch.getDataRowCount());
+            this.outgoingBatch.setExtractInsertRowCount(this.outgoingBatch.getDataInsertRowCount());
             checkSendChildRequests(batchFromDatabase, resource, stats);
             this.dataExtractorService.outgoingBatchService.updateOutgoingBatch(this.outgoingBatch);
         } else {
@@ -307,6 +309,7 @@ protected void nextBatch() {
         this.outgoingBatch = this.batches.remove(0);
         this.outgoingBatch.setDataRowCount(0);
         this.outgoingBatch.setDataInsertRowCount(0);
+        this.outgoingBatch.setExtractStartTime(new Date());
         if (this.finishedBatches.size() > 0) {
             this.outgoingBatch.setExtractCount(this.outgoingBatch.getExtractCount() + 1);
         }