This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 255c7e87330 Pipe: Fixed TsFile resource leak issue (#16090)
255c7e87330 is described below
commit 255c7e87330c7fc31d3f8e94507f8b2a31eb7b89
Author: Zhenyu Luo <[email protected]>
AuthorDate: Mon Aug 4 14:16:30 2025 +0800
Pipe: Fixed TsFile resource leak issue (#16090)
---
.../source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java
index f28dada73ab..25256238794 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java
@@ -169,6 +169,7 @@ public class PipeRealtimeDataRegionHybridSource extends
PipeRealtimeDataRegionSo
// If the state is USING_TABLET, discard the event
PipeTsFileEpochProgressIndexKeeper.getInstance()
.eliminateProgressIndex(dataRegionId, pipeName,
event.getTsFileEpoch().getFilePath());
+
event.decreaseReferenceCount(PipeRealtimeDataRegionHybridSource.class.getName(),
false);
return;
case EMPTY:
case USING_TSFILE:
