From e0ff697f811ae1fab86bfe725fc8ccfc2b14e74a Mon Sep 17 00:00:00 2001 From: shuwenwei Date: Thu, 5 Feb 2026 15:29:15 +0800 Subject: [PATCH] Prevent modified flag from being overwritten --- .../src/main/java/org/apache/tsfile/file/header/PageHeader.java | 2 +- .../java/org/apache/tsfile/file/metadata/ChunkMetadata.java | 2 +- .../org/apache/tsfile/file/metadata/TimeseriesMetadata.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/java/tsfile/src/main/java/org/apache/tsfile/file/header/PageHeader.java b/java/tsfile/src/main/java/org/apache/tsfile/file/header/PageHeader.java index 70387419f..8ba394bc4 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/file/header/PageHeader.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/file/header/PageHeader.java @@ -164,7 +164,7 @@ public boolean isModified() { } public void setModified(boolean modified) { - this.modified = modified; + this.modified |= modified; } /** max page header size without statistics. */ diff --git a/java/tsfile/src/main/java/org/apache/tsfile/file/metadata/ChunkMetadata.java b/java/tsfile/src/main/java/org/apache/tsfile/file/metadata/ChunkMetadata.java index e491d7bb2..52245a1db 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/file/metadata/ChunkMetadata.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/file/metadata/ChunkMetadata.java @@ -288,7 +288,7 @@ public boolean isModified() { @Override public void setModified(boolean modified) { - this.modified = modified; + this.modified |= modified; } public static long calculateRamSize(String measurementId, TSDataType dataType) { diff --git a/java/tsfile/src/main/java/org/apache/tsfile/file/metadata/TimeseriesMetadata.java b/java/tsfile/src/main/java/org/apache/tsfile/file/metadata/TimeseriesMetadata.java index c7f97a908..5a81a4a7c 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/file/metadata/TimeseriesMetadata.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/file/metadata/TimeseriesMetadata.java @@ -340,7 +340,7 @@ public boolean isModified() { @Override public void setModified(boolean modified) { - this.modified = modified; + this.modified |= modified; } @Override