This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch mod-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/mod-fix by this push:
new 6dbfca8f4bc shop
6dbfca8f4bc is described below
commit 6dbfca8f4bc91fd5f742f847949b434036ea8463
Author: Caideyipi <[email protected]>
AuthorDate: Fri Mar 27 19:20:12 2026 +0800
shop
---
.../historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java
index 32fcece4115..66f8d48ce28 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java
@@ -904,7 +904,8 @@ public class PipeHistoricalDataRegionTsFileAndDeletionSource
return isReferenceCountIncreased ? event : null;
} finally {
try {
- PipeDataNodeResourceManager.tsfile().unpinTsFileResource(resource,
pipeName);
+ PipeDataNodeResourceManager.tsfile()
+ .unpinTsFileResource(resource, shouldTransferModFile, pipeName);
} catch (final IOException e) {
LOGGER.warn(
"Pipe {}@{}: failed to unpin TsFileResource after creating event,
original path: {}",
@@ -989,7 +990,8 @@ public class PipeHistoricalDataRegionTsFileAndDeletionSource
if (resource instanceof TsFileResource) {
try {
PipeDataNodeResourceManager.tsfile()
- .unpinTsFileResource((TsFileResource) resource, pipeName);
+ .unpinTsFileResource(
+ (TsFileResource) resource, shouldTransferModFile,
pipeName);
} catch (final IOException e) {
LOGGER.warn(
"Pipe {}@{}: failed to unpin TsFileResource after dropping
pipe, original path: {}",
