Update PipeEventCollector.java

apache · Oct 18, 2024 · 1a49b94 · 1a49b94
1 parent da7531d
commit 1a49b94
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/...node/src/main/java/org/apache/iotdb/db/pipe/agent/task/connection/PipeEventCollector.java b/...node/src/main/java/org/apache/iotdb/db/pipe/agent/task/connection/PipeEventCollector.java
@@ -120,12 +120,11 @@ private void parseAndCollectEvent(final PipeTsFileInsertionEvent sourceEvent) th
       return;
     }
 
-    if (!forceTabletFormat && !sourceEvent.shouldParseTimeOrPattern()) {
-      collectEvent(sourceEvent);
-      return;
-    }
-
-    if (sourceEvent.isTableModelEvent() && sourceEvent.getTablePattern() == null) {
+    if (!forceTabletFormat
+        && (!sourceEvent.shouldParseTimeOrPattern()
+            || (sourceEvent.isTableModelEvent()
+                && sourceEvent.getTablePattern() == null
+                && !sourceEvent.shouldParseTime()))) {
       collectEvent(sourceEvent);
       return;
     }