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()) {