0005596: Failure to Flush when using ConvertToReload router.

JumpMind · Nov 25, 2022 · 3310ff6 · 3310ff6
1 parent 7808473
commit 3310ff6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/ConvertToReloadRouter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/ConvertToReloadRouter.java
@@ -240,6 +240,7 @@ protected void queueEvents(ChannelRouterContext context, ISqlTransaction transac
             insertBatchMs += (System.currentTimeMillis() - ts);
         }
         origBatch.setLoadId(loadId);
+        transaction.flush();
     }
 
     protected String getTempTableSql(RouterInfo routerInfo, TableInfo tableInfo, long loadId) {