This is an automated email from the ASF dual-hosted git repository.

justinchen pushed a commit to branch hook-13
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/hook-13 by this push:
     new 5c1369c9928 fix
5c1369c9928 is described below

commit 5c1369c992882ae3e5085210d666d9e7c41dbe93
Author: Caideyipi <[email protected]>
AuthorDate: Wed Mar 25 19:58:09 2026 +0800

    fix
---
 .../db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java
index 858c425c3e6..f099301a63c 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java
@@ -375,6 +375,17 @@ public class PipeTsFileInsertionEvent extends EnrichedEvent
         || startTime <= resource.getFileEndTime() && 
resource.getFileStartTime() <= endTime;
   }
 
+  @Override
+  public boolean shouldParseTime() {
+    if (!isTimeParsed
+        && Objects.nonNull(resource)
+        && startTime <= resource.getFileStartTime()
+        && resource.getFileEndTime() <= endTime) {
+      isTimeParsed = true;
+    }
+    return !isTimeParsed;
+  }
+
   @Override
   public boolean mayEventPathsOverlappedWithPattern() {
     if (Objects.isNull(resource) || !resource.isClosed()) {

Reply via email to