diff --git a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/FileSyncPushUriHandler.java b/symmetric-server/src/main/java/org/jumpmind/symmetric/web/FileSyncPushUriHandler.java
index 969cd9d95f..24475d769a 100644
--- a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/FileSyncPushUriHandler.java
+++ b/symmetric-server/src/main/java/org/jumpmind/symmetric/web/FileSyncPushUriHandler.java
@@ -73,6 +73,8 @@ public void handle(HttpServletRequest req, HttpServletResponse res) throws IOExc
 
             }
         }
+        
+        res.flushBuffer();
 
     }
 
diff --git a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/PushUriHandler.java b/symmetric-server/src/main/java/org/jumpmind/symmetric/web/PushUriHandler.java
index 1eedb7b148..8c67910450 100644
--- a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/PushUriHandler.java
+++ b/symmetric-server/src/main/java/org/jumpmind/symmetric/web/PushUriHandler.java
@@ -53,6 +53,7 @@ public PushUriHandler(IParameterService parameterService, IDataLoaderService dat
         this.dataLoaderService = dataLoaderService;
         this.statisticManager = statisticManager;
         this.nodeService = nodeService;
+        log.info("Patched version of PushUriHandler with buffer flush is deployed");
     }
 
     public void handle(HttpServletRequest req, HttpServletResponse res) throws IOException,
@@ -65,6 +66,7 @@ public void handle(HttpServletRequest req, HttpServletResponse res) throws IOExc
 
         push(nodeId, inputStream, outputStream);
 
+        res.flushBuffer();
         log.debug("Push completed for {}", nodeId);
 
     }