diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
index e1958b4276..2b2309ec94 100644
--- a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
+++ b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
@@ -168,6 +168,9 @@ public IDataLoaderStatistics loadDataBatch(String batchData) throws IOException
         try {
             while (dataLoader.hasNext()) {
                 dataLoader.load();
+                IncomingBatchHistory history = new IncomingBatchHistory(dataLoader.getContext());
+                history.setValues(dataLoader.getStatistics(), true);
+                fireBatchComplete(dataLoader, history);                
             }
         } finally {
             stats = dataLoader.getStatistics();