(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Fixed the bug that compaction may cause progressIndex lost (#16258) (#16262)

[justinchen]

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

justinchen pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 6ecf04d893e [To dev/1.3] Pipe: Fixed the bug that compaction may cause 
progressIndex lost (#16258) (#16262)
6ecf04d893e is described below

commit 6ecf04d893e3abd6c344d9db83b000e1178f2528
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Tue Aug 26 11:42:50 2025 +0800

    [To dev/1.3] Pipe: Fixed the bug that compaction may cause progressIndex 
lost (#16258) (#16262)
---
 .../iotdb/db/storageengine/dataregion/tsfile/TsFileResource.java       | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileResource.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileResource.java
index c1a67400f4d..c8d3f69aa4d 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileResource.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileResource.java
@@ -1198,7 +1198,8 @@ public class TsFileResource {
     }
 
     if (!maxProgressIndex.compareAndSet(null, progressIndex)) {
-      
maxProgressIndex.get().updateToMinimumEqualOrIsAfterProgressIndex(progressIndex);
+      maxProgressIndex.updateAndGet(
+          index -> 
index.updateToMinimumEqualOrIsAfterProgressIndex(progressIndex));
     }
   }