From 3310ff6c25458cf636dc669a6bd089c3758cab41 Mon Sep 17 00:00:00 2001 From: jakobvanmeter Date: Fri, 25 Nov 2022 10:26:03 -0500 Subject: [PATCH] 0005596: Failure to Flush when using ConvertToReload router. --- .../java/org/jumpmind/symmetric/route/ConvertToReloadRouter.java | 1 + 1 file changed, 1 insertion(+) 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 index 92f1f4c8b9..47c54c5f08 100644 --- 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) {