(iotdb) 01/01: Pipe: GC device2Measurements in PipeRealtimeEvent in time to avoid OOM when insertion is in high load

[ro...@apache.org]

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

rong pushed a commit to branch fix-pipe-oom
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit f1d5744887346cb771ce856e9f744ffe95b25971
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Thu Nov 7 20:10:00 2024 +0800

    Pipe: GC device2Measurements in PipeRealtimeEvent in time to avoid OOM when insertion is in high load
---
 .../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 f216b9df332..bf0abd9c9fa 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
@@ -199,7 +199,9 @@ public class PipeRealtimeEvent extends EnrichedEvent {
         event.shallowCopySelfAndBindPipeTaskMetaForProgressReport(
             pipeName, creationTime, pipeTaskMeta, treePattern, tablePattern, 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,
         treePattern,
         tablePattern,