From 8530b50bdaa78931074c0a00e4212aa211d4cce1 Mon Sep 17 00:00:00 2001
From: chenson42 <chenson42@gmail.com>
Date: Tue, 6 Aug 2013 14:50:21 +0000
Subject: [PATCH] 0001368: On extraction retries the data_event_count is not
 reset

---
 .../jumpmind/symmetric/service/impl/DataExtractorService.java | 4 +++-
 1 file changed, 3 insertions(+), 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 7bb52f34d8..94acb4c298 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
@@ -607,6 +607,7 @@ protected OutgoingBatch extractOutgoingBatch(ProcessInfo processInfo, Node targe
             IDataWriter dataWriter, OutgoingBatch currentBatch, boolean useStagingDataWriter, 
             boolean updateBatchStatistics, ExtractMode mode) {
         if (currentBatch.getStatus() != Status.OK || ExtractMode.EXTRACT_ONLY == mode) {
+            
             Node sourceNode = nodeService.findIdentity();
 
             TransformWriter transformExtractWriter = null;
@@ -649,7 +650,7 @@ protected OutgoingBatch extractOutgoingBatch(ProcessInfo processInfo, Node targe
                 } finally {
                     transformExtractWriter.close();
                 }
-            } else if (!isPreviouslyExtracted(currentBatch)) {
+            } else if (!isPreviouslyExtracted(currentBatch)) {                
                 int maxPermits = parameterService.getInt(ParameterConstants.CONCURRENT_WORKERS);
                 String semaphoreKey = useStagingDataWriter ? Long.toString(currentBatch
                         .getBatchId()) : currentBatch.getNodeBatchId();
@@ -670,6 +671,7 @@ protected OutgoingBatch extractOutgoingBatch(ProcessInfo processInfo, Node targe
 
                     synchronized (lock) {
                         if (!isPreviouslyExtracted(currentBatch)) {
+                            currentBatch.resetStats();
                             currentBatch.setExtractCount(currentBatch.getExtractCount() + 1);
                             if (updateBatchStatistics) {
                                 changeBatchStatus(Status.QY, currentBatch, mode);