From 43db58c8dbc3a7ab2cf109850e230a594bc47947 Mon Sep 17 00:00:00 2001
From: chenson42 <chenson42@gmail.com>
Date: Mon, 27 Feb 2012 21:51:14 +0000
Subject: [PATCH] dev checkin.

---
 .../jumpmind/symmetric/service/impl/IncomingBatchService.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
index d5465e3f45..4d1f57e5b0 100644
--- a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
+++ b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
@@ -166,6 +166,8 @@ public boolean acquireIncomingBatch(IncomingBatch batch) {
                     batch.setDatabaseMillis(existingBatch.getDatabaseMillis());
                     batch.setNetworkMillis(existingBatch.getNetworkMillis());
                     batch.setFilterMillis(existingBatch.getFilterMillis());
+                    batch.setSkipCount(existingBatch.getSkipCount() + 1);
+                    batch.setStatementCount(existingBatch.getStatementCount());
                     
                     existingBatch.setSkipCount(existingBatch.getSkipCount() + 1);
                     log.warn("Skipping batch {}", batch.getNodeBatchId());