diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
index b9260bc212..5459849f62 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -1567,7 +1567,7 @@ public CsvData next() {
             } while (data != null
                     && routingContext != null
                     && !routerService.shouldDataBeRouted(routingContext,
-                            new DataMetaData((Data) data, targetTable, triggerRouter.getRouter(),
+                            new DataMetaData((Data) data, sourceTable, triggerRouter.getRouter(),
                                     routingContext.getChannel()), node, true, StringUtils
                                     .isNotBlank(triggerRouter.getInitialLoadSelect()), triggerRouter));