diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java index 862977c7c9..c213894214 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java @@ -352,7 +352,7 @@ private boolean isFileSyncEnabled(Table table, CsvData data) { private boolean isTransformFlushNeeded(Table table) { return matchesTable(table, TableConstants.SYM_TRANSFORM_COLUMN) - || matchesTable(table, TableConstants.SYM_TRANSFORM_TABLE); + || matchesTable(table, TableConstants.SYM_TRANSFORM_TABLE) || matchesTable(table, TableConstants.SYM_NODE_GROUP_LINK); } private boolean isExtensionFlushNeeded(Table table) { diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/ConfigurationChangedDataRouter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/ConfigurationChangedDataRouter.java index 7c821431e9..012f081b3e 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/ConfigurationChangedDataRouter.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/ConfigurationChangedDataRouter.java @@ -710,6 +710,8 @@ public void contextCommitted(SimpleRouterContext routingContext) { log.info("About to refresh the cache of node group link because new configuration came through the data router"); engine.getConfigurationService().clearCache(); engine.getNodeService().flushNodeGroupCache(); + log.info("About to refresh the cache of transformation because new configuration came through the data router"); + engine.getTransformService().clearCache(); } if (routingContext.get(CTX_KEY_FILE_SYNC_TRIGGERS_NEEDED) != null