diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
index f4d2b88349..a571df666b 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
@@ -915,6 +915,12 @@ public void batchInError(DataContext context, Throwable ex) {
                      */
                     throw ex;
                 }
+                
+                /*
+                 * Reread batch to make sure it wasn't set to IG or OK
+                 */
+                currentBatch = engine.getIncomingBatchService().findIncomingBatch(currentBatch.getBatchId(), currentBatch.getNodeId());
+                
                 Batch batch = context.getBatch();
                 if (context.getWriter() != null
                         && context.getReader().getStatistics().get(batch) != null