0006055: Multi-threaded routing by channel

JumpMind · Oct 26, 2023 · 4b56b8a · 4b56b8a
1 parent 008258e
commit 4b56b8a
Showing 1 changed file with 1 addition and 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
@@ -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) {