This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch rc/2.0.4 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 64ec540244c71190303794f94df987e39d1fb65c Author: VGalaxies <[email protected]> AuthorDate: Thu May 22 09:30:18 2025 +0800 Subscription: decrease reference count for managed parsed tsfile event (#15555) (cherry picked from commit 326432e83d72d44c90c146e206bb99ea2ed9fdd5) --- .../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 }
