0002301: If an incoming batch is marked as IG when it is loading and …

…the batch fails, then the IG status is lost
JumpMind · May 18, 2015 · 1f1d333 · 1f1d333
1 parent 971550b
commit 1f1d333
Showing 1 changed file with 6 additions and 0 deletions.
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
@@ -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