(iotdb) branch dev/1.3 updated: Pipe: GC device2Measurements in PipeRealtimeEvent in time to avoid OOM when insertion is in high load (#14018) (#14023)

[rong]

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

rong pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new b5bf78f442d Pipe: GC device2Measurements in PipeRealtimeEvent in time 
to avoid OOM when insertion is in high load (#14018) (#14023)
b5bf78f442d is described below

commit b5bf78f442de12e1ef8f7fe976e79d9d6a6799b7
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Fri Nov 8 15:37:00 2024 +0800

    Pipe: GC device2Measurements in PipeRealtimeEvent in time to avoid OOM when 
insertion is in high load (#14018) (#14023)
    
    (cherry picked from commit caac607464359cb194b07bd1fa6c985bb745826e)
---
 .../org/apache/iotdb/db/pipe/event/realtime/PipeRealtimeEvent.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/realtime/PipeRealtimeEvent.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/realtime/PipeRealtimeEvent.java
index 25f6c401779..3bf32f00ea9 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/realtime/PipeRealtimeEvent.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/realtime/PipeRealtimeEvent.java
@@ -171,7 +171,9 @@ public class PipeRealtimeEvent extends EnrichedEvent {
         event.shallowCopySelfAndBindPipeTaskMetaForProgressReport(
             pipeName, creationTime, pipeTaskMeta, pattern, startTime, endTime),
         this.tsFileEpoch,
-        this.device2Measurements,
+        // device2Measurements is not used anymore, so it is not copied.
+        // If null is not passed, the field will not be GCed and may cause OOM.
+        null,
         pipeTaskMeta,
         pattern,
         startTime,