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

jackietien pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/tsfile.git


The following commit(s) were added to refs/heads/develop by this push:
     new 0e7dcc6b Prevent modified flag from being overwritten#721
0e7dcc6b is described below

commit 0e7dcc6b70d9aa0541df6b21c4df1c76fe868394
Author: shuwenwei <[email protected]>
AuthorDate: Thu Feb 5 15:51:00 2026 +0800

    Prevent modified flag from being overwritten#721
---
 java/tsfile/src/main/java/org/apache/tsfile/file/header/PageHeader.java | 2 +-
 .../src/main/java/org/apache/tsfile/file/metadata/ChunkMetadata.java    | 2 +-
 .../main/java/org/apache/tsfile/file/metadata/TimeseriesMetadata.java   | 2 +-
 .../org/apache/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 78d80f32..d752d509 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 class PageHeader implements IMetadata {
   }
 
   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 a76ef65c..42648621 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 class ChunkMetadata implements IChunkMetadata {
 
   @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 96f9c562..1e254e06 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 class TimeseriesMetadata implements 
ITimeSeriesMetadata {
 
   @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 42a802c9..b3090a57 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 abstract class AbstractAlignedPageReader implements 
IPageReader {
 
   @Override
   public void setModified(boolean modified) {
-    this.isModified = modified;
+    this.isModified |= modified;
   }
 
   @Override

Reply via email to