Pipe: Fixed the bug that compaction may cause progressIndex lost (apache#16258)

Caideyipi · web-flow · commit 4937c453e434 · 2025-08-26T09:46:25.000+08:00
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
@@ -1387,7 +1387,8 @@ public void updateProgressIndex(ProgressIndex progressIndex) {
     }
 
     if (!maxProgressIndex.compareAndSet(null, progressIndex)) {
-      maxProgressIndex.get().updateToMinimumEqualOrIsAfterProgressIndex(progressIndex);
+      maxProgressIndex.updateAndGet(
+          index -> index.updateToMinimumEqualOrIsAfterProgressIndex(progressIndex));
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -1387,7 +1387,8 @@ public void updateProgressIndex(ProgressIndex progressIndex) {`
`1387`	`1387`	`}`
`1388`	`1388`
`1389`	`1389`	`if (!maxProgressIndex.compareAndSet(null, progressIndex)) {`
`1390`		`- maxProgressIndex.get().updateToMinimumEqualOrIsAfterProgressIndex(progressIndex);`
	`1390`	`+ maxProgressIndex.updateAndGet(`
	`1391`	`+ index -> index.updateToMinimumEqualOrIsAfterProgressIndex(progressIndex));`
`1391`	`1392`	`}`
`1392`	`1393`	`}`
`1393`	`1394`