diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/connection/PipeEventCollector.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/connection/PipeEventCollector.java
index b21fc8271b2e..d63c1e393254 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/connection/PipeEventCollector.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/connection/PipeEventCollector.java
@@ -120,7 +120,8 @@ private void parseAndCollectEvent(final PipeTsFileInsertionEvent sourceEvent) th
     if (!forceTabletFormat
         && (!sourceEvent.shouldParseTimeOrPattern()
             || (sourceEvent.isTableModelEvent()
-                && sourceEvent.getTablePattern() == null
+                && (sourceEvent.getTablePattern() == null
+                    || !sourceEvent.getTablePattern().hasTablePattern())
                 && !sourceEvent.shouldParseTime()))) {
       collectEvent(sourceEvent);
       return;
diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/TablePattern.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/TablePattern.java
index f60e343a23c9..1fe957a24540 100644
--- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/TablePattern.java
+++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/TablePattern.java
@@ -95,6 +95,10 @@ public String getTablePattern() {
     return tablePattern == null ? EXTRACTOR_TABLE_NAME_DEFAULT_VALUE : tablePattern.pattern();
   }
 
+  public boolean hasTablePattern() {
+    return tablePattern != null;
+  }
+
   /**
    * Interpret from source parameters and get a pipe pattern.
    *