dev checkin.

JumpMind · Feb 27, 2012 · 43db58c · 43db58c
1 parent 3268cc9
commit 43db58c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...ymmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java b/...ymmetric-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());