From 4b56b8a4e0892908a57a2ed0a8cb450208d60cd0 Mon Sep 17 00:00:00 2001
From: Eric Long <elong@jumpmind.com>
Date: Thu, 26 Oct 2023 11:26:30 -0400
Subject: [PATCH] 0006055: Multi-threaded routing by channel

---
 .../org/jumpmind/symmetric/extract/SelectFromSymDataSource.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromSymDataSource.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromSymDataSource.java
index 1b609ae86e..b708b711c8 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromSymDataSource.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromSymDataSource.java
@@ -156,7 +156,7 @@ public CsvData next() {
                     data.setNoBinaryOldData(requiresLobSelectedFromSource || dialectHasNoOldBinaryData);
                     outgoingBatch.incrementExtractRowCount();
                     outgoingBatch.incrementExtractRowCount(data.getDataEventType());
-                    if (!containsBigLob && (data.getDataEventType().equals(DataEventType.INSERT) || data.getDataEventType().equals(DataEventType.UPDATE))) {
+                    if (data.getDataEventType().equals(DataEventType.INSERT) || data.getDataEventType().equals(DataEventType.UPDATE)) {
                         int expectedCommaCount = triggerHistory.getParsedColumnNames().length;
                         int commaCount = StringUtils.countMatches(data.getRowData(), ",") + 1;
                         if (commaCount < expectedCommaCount) {