diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchServiceSqlMap.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchServiceSqlMap.java
index 1c02dcff4c..31df3c2f07 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchServiceSqlMap.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchServiceSqlMap.java
@@ -44,7 +44,7 @@ public OutgoingBatchServiceSqlMap(IDatabasePlatform platform,
                 "update $(outgoing_batch) set ignore_count=1, status='OK', error_flag=0, last_update_time=current_timestamp where load_id=?");
 
         putSql("cancelChannelBatchesSelectSql",
-                "select node_id, batch_id from sym_outgoing_batch where channel_id = ? and status <> ? and summary=? and sent_count=0");
+                "select node_id, batch_id from $(outgoing_batch) where channel_id = ? and status <> ? and summary=? and sent_count=0");
 
         putSql("cancelChannelBatchSql",
                 "update $(outgoing_batch) set ignore_count=1, status='OK', error_flag=0, last_update_time=current_timestamp where node_id = ? and batch_id = ?");