(iotdb) branch rc/1.3.1 updated: fix PipeRawTabletInsertionEvent compile error

[haonan]

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

haonan pushed a commit to branch rc/1.3.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rc/1.3.1 by this push:
     new 6d66dfd0eaf fix PipeRawTabletInsertionEvent compile error
6d66dfd0eaf is described below

commit 6d66dfd0eaf1c39b0e0a5dcc3fd06882da807134
Author: HTHou <hhao...@outlook.com>
AuthorDate: Tue Mar 5 10:57:23 2024 +0800

    fix PipeRawTabletInsertionEvent compile error
---
 .../pipe/event/common/tablet/PipeRawTabletInsertionEvent.java  | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletInsertionEvent.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletInsertionEvent.java
index 52f30754a9b..94dd2b11cbe 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletInsertionEvent.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletInsertionEvent.java
@@ -24,8 +24,6 @@ import 
org.apache.iotdb.commons.consensus.index.impl.MinimumProgressIndex;
 import org.apache.iotdb.commons.pipe.task.meta.PipeTaskMeta;
 import org.apache.iotdb.commons.utils.TestOnly;
 import org.apache.iotdb.db.pipe.event.EnrichedEvent;
-import org.apache.iotdb.db.pipe.resource.PipeResourceManager;
-import org.apache.iotdb.db.pipe.resource.memory.PipeTabletMemoryBlock;
 import org.apache.iotdb.pipe.api.access.Row;
 import org.apache.iotdb.pipe.api.collector.RowCollector;
 import org.apache.iotdb.pipe.api.event.dml.insertion.TabletInsertionEvent;
@@ -42,8 +40,6 @@ public class PipeRawTabletInsertionEvent extends 
EnrichedEvent implements Tablet
   private final EnrichedEvent sourceEvent;
   private boolean needToReport;
 
-  private PipeTabletMemoryBlock allocatedMemoryBlock;
-
   private TabletInsertionDataContainer dataContainer;
 
   private PipeRawTabletInsertionEvent(
@@ -99,13 +95,11 @@ public class PipeRawTabletInsertionEvent extends 
EnrichedEvent implements Tablet
 
   @Override
   public boolean internallyIncreaseResourceReferenceCount(String 
holderMessage) {
-    allocatedMemoryBlock = PipeResourceManager.memory().forceAllocate(tablet);
     return true;
   }
 
   @Override
   public boolean internallyDecreaseResourceReferenceCount(String 
holderMessage) {
-    allocatedMemoryBlock.close();
     return true;
   }
 
@@ -214,8 +208,8 @@ public class PipeRawTabletInsertionEvent extends 
EnrichedEvent implements Tablet
   @Override
   public String toString() {
     return String.format(
-            "PipeRawTabletInsertionEvent{tablet=%s, isAligned=%s, 
sourceEvent=%s, needToReport=%s, allocatedMemoryBlock=%s, dataContainer=%s}",
-            tablet, isAligned, sourceEvent, needToReport, 
allocatedMemoryBlock, dataContainer)
+            "PipeRawTabletInsertionEvent{tablet=%s, isAligned=%s, 
sourceEvent=%s, needToReport=%s, dataContainer=%s}",
+            tablet, isAligned, sourceEvent, needToReport, dataContainer)
         + " - "
         + super.toString();
   }