[To dev/1.3] Pipe: Fixed the bug that concurrent modification / compaction of the mod file may cause mod hard-link failure (#16044)

Caideyipi · web-flow · commit a0b4978f5374 · 2025-07-28T17:17:00.000+08:00
* mod

* fix
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/tsfile/PipeTsFileResourceManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/tsfile/PipeTsFileResourceManager.java
@@ -352,7 +352,10 @@ public void pinTsFileResource(
       throws IOException {
     increaseFileReference(resource.getTsFile(), true, pipeName);
     if (withMods && resource.getModFile().exists()) {
-      increaseFileReference(new File(resource.getModFile().getFilePath()), false, pipeName);
+      // Avoid mod compaction
+      synchronized (resource.getModFile()) {
+        increaseFileReference(new File(resource.getModFile().getFilePath()), false, pipeName);
+      }
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -352,7 +352,10 @@ public void pinTsFileResource(`
`352`	`352`	`throws IOException {`
`353`	`353`	`increaseFileReference(resource.getTsFile(), true, pipeName);`
`354`	`354`	`if (withMods && resource.getModFile().exists()) {`
`355`		`- increaseFileReference(new File(resource.getModFile().getFilePath()), false, pipeName);`
	`355`	`+ // Avoid mod compaction`
	`356`	`+ synchronized (resource.getModFile()) {`
	`357`	`+ increaseFileReference(new File(resource.getModFile().getFilePath()), false, pipeName);`
	`358`	`+ }`
`356`	`359`	`}`
`357`	`360`	`}`
`358`	`361`