From a64a0441205ddbe6c5d0294bea768f316d93b2a0 Mon Sep 17 00:00:00 2001
From: Chris Henson <chenson42@gmail.com>
Date: Sun, 2 Jul 2017 12:32:00 -0400
Subject: [PATCH] 0003168: Create CSV Router to route data from a CSV file

---
 .../symmetric/service/impl/DataExtractorService.java         | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 54f0d028f1..07ac561b6a 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
@@ -1882,13 +1882,14 @@ public CsvData next() {
                         TriggerHistory triggerHistory = data.getTriggerHistory();
                         Trigger trigger = triggerRouterService.getTriggerById(
                                 triggerHistory.getTriggerId(), false);
-                        if (trigger != null || triggerHistory.getTriggerId().equals(AbstractFileParsingRouter.TRIGGER_ID_FILE_PARSER)) {
+                        boolean isFileParserRouter = triggerHistory.getTriggerId().equals(AbstractFileParsingRouter.TRIGGER_ID_FILE_PARSER);
+                        if (trigger != null || isFileParserRouter) {
                             if (lastTriggerHistory == null || lastTriggerHistory
                                     .getTriggerHistoryId() != triggerHistory.getTriggerHistoryId() || 
                                     lastRouterId == null || !lastRouterId.equals(routerId)) {
                                 
                                 this.sourceTable = columnsAccordingToTriggerHistory.lookup(
-                                            routerId, triggerHistory, false, false);
+                                            routerId, triggerHistory, false, !isFileParserRouter);
                                 
                                 this.targetTable = columnsAccordingToTriggerHistory.lookup(
                                         routerId, triggerHistory, true, false);