Added a flush after an initial load table is written.

JumpMind · Oct 17, 2007 · 135fe63 · 135fe63
1 parent 9a5e347
commit 135fe63
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/extract/csv/StreamReloadDataCommand.java b/symmetric/src/main/java/org/jumpmind/symmetric/extract/csv/StreamReloadDataCommand.java
@@ -44,6 +44,7 @@ public void execute(BufferedWriter out, Data data, DataExtractorContext context)
         Trigger trigger = configurationService.getTriggerById(data.getAudit().getTriggerId());
         Node node = nodeService.findNode(context.getBatch().getNodeId());
         dataExtractorService.extractInitialLoadWithinBatchFor(node, trigger, new InternalOutgoingTransport(out));
+        out.flush();
     }
 
     public void setDataExtractorService(IDataExtractorService dataExtractorService) {