(iotdb) branch master updated: Subscription: decrease reference count for managed parsed tsfile event (#15555)

[haonan]

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

haonan 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 326432e83d7 Subscription: decrease reference count for managed parsed 
tsfile event (#15555)
326432e83d7 is described below

commit 326432e83d72d44c90c146e206bb99ea2ed9fdd5
Author: VGalaxies <vgalax...@apache.org>
AuthorDate: Thu May 22 09:30:18 2025 +0800

    Subscription: decrease reference count for managed parsed tsfile event 
(#15555)
---
 .../db/subscription/event/batch/SubscriptionPipeTsFileEventBatch.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatch.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatch.java
index 7902a069aa0..572a785c41b 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatch.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatch.java
@@ -22,6 +22,7 @@ package org.apache.iotdb.db.subscription.event.batch;
 import org.apache.iotdb.commons.pipe.event.EnrichedEvent;
 import 
org.apache.iotdb.db.pipe.connector.payload.evolvable.batch.PipeTabletEventTsFileBatch;
 import 
org.apache.iotdb.db.pipe.event.common.tablet.PipeRawTabletInsertionEvent;
+import org.apache.iotdb.db.pipe.event.common.tsfile.PipeTsFileInsertionEvent;
 import 
org.apache.iotdb.db.subscription.broker.SubscriptionPrefetchingTsFileQueue;
 import org.apache.iotdb.db.subscription.event.SubscriptionEvent;
 import 
org.apache.iotdb.db.subscription.event.pipe.SubscriptionPipeTsFileBatchEvents;
@@ -102,6 +103,7 @@ public class SubscriptionPipeTsFileEventBatch extends 
SubscriptionPipeEventBatch
     } finally {
       try {
         event.close();
+        ((PipeTsFileInsertionEvent) 
event).decreaseReferenceCount(this.getClass().getName(), false);
       } catch (final Exception ignored) {
         // no exceptions will be thrown
       }