diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/SubSelectDataRouter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/SubSelectDataRouter.java
index 6c7fd54b47..172e39feb7 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/SubSelectDataRouter.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/SubSelectDataRouter.java
@@ -78,7 +78,7 @@ public Set<String> routeToNodes(SimpleRouterContext routingContext, DataMetaData
                 sqlParams.put("DATA_EVENT_TYPE", dataMetaData.getData().getDataEventType().name());
                 sqlParams.put("TABLE_NAME", dataMetaData.getData().getTableName());
                 ISqlTemplate template = symmetricDialect.getPlatform().getSqlTemplate();
-                List<String> ids = template.query(String.format("%s%s", sql, subSelect),
+                List<String> ids = template.query(String.format("%s(%s)", sql, subSelect),
                         new StringMapper(), sqlParams);
                 if (ids != null) {
                     nodeIds = new HashSet<String>(ids);