diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java index a7796c153b..5ac84d2d11 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java @@ -1569,9 +1569,10 @@ public boolean syncTriggers(List tables, boolean force) { activeTriggerHistories, true); for (Table table : tables) { /* Re-lookup just in case the table was just altered */ - table = symmetricDialect.getTargetPlatform(table.getName()).getTableFromCache(table.getCatalog(), table.getSchema(), table.getName(), true); + IDatabasePlatform targetPlatform = symmetricDialect.getTargetPlatform(table.getName()); + table = targetPlatform.getTableFromCache(table.getCatalog(), table.getSchema(), table.getName(), true); for (Trigger trigger : triggersForCurrentNode) { - if (trigger.matches(table, platform.getDefaultCatalog(), platform.getDefaultSchema(), ignoreCase) && + if (trigger.matches(table, targetPlatform.getDefaultCatalog(), targetPlatform.getDefaultSchema(), ignoreCase) && (!trigger.isSourceTableNameWildCarded() || !trigger.isSourceTableNameExpanded() || !containsExactMatchForSourceTableName(table, triggersForCurrentNode, ignoreCase))) { List triggerTableSupportingInfoList = triggerToTableSupportingInfo.get(trigger.getTriggerId());