0003741: Individual Table reloads should not clear a node's incoming …

…batches
JumpMind · Oct 3, 2018 · 9e4649f · 9e4649f
1 parent 98a6142
commit 9e4649f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
@@ -555,7 +555,7 @@ public void insertReloadEvents(Node targetNode, boolean reverse, List<TableReloa
                         close(transaction);
                     }
 
-                    if (!reverse) {
+                    if (!reverse && isFullLoad) {
                         /*
                          * Remove all incoming events for the node that we are
                          * starting a reload for