From 5679380e2cce4dc0e42f82fce7ab774e3a51c4b7 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 +- .../tsfile/read/reader/page/AbstractAlignedPageReader.java | 2 +- 4 files changed, 4 insertions(+), 4 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 78d80f32f..d752d509f 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 @@ -170,7 +170,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 a76ef65c2..426486215 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 @@ -334,7 +334,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 96f9c5623..1e254e065 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 @@ -355,7 +355,7 @@ public boolean isModified() { @Override public void setModified(boolean modified) { - this.modified = modified; + this.modified |= modified; } @Override diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/reader/page/AbstractAlignedPageReader.java b/java/tsfile/src/main/java/org/apache/tsfile/read/reader/page/AbstractAlignedPageReader.java index 42a802c90..b3090a575 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/reader/page/AbstractAlignedPageReader.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/reader/page/AbstractAlignedPageReader.java @@ -350,7 +350,7 @@ public boolean isModified() { @Override public void setModified(boolean modified) { - this.isModified = modified; + this.isModified |= modified; } @Override