You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/11/08 05:26:06 UTC
(iotdb) branch fix-pipe-oom-1.3 created (now 481d48d9602)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch fix-pipe-oom-1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 481d48d9602 Pipe: GC device2Measurements in PipeRealtimeEvent in time to avoid OOM when insertion is in high load (#14018)
This branch includes the following new commits:
new 481d48d9602 Pipe: GC device2Measurements in PipeRealtimeEvent in time to avoid OOM when insertion is in high load (#14018)
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: Pipe: GC device2Measurements in PipeRealtimeEvent in time to avoid OOM when insertion is in high load (#14018)
Posted by ro...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch fix-pipe-oom-1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 481d48d9602fea04baf445c0f76dadc4bb3520bf
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Fri Nov 8 10:27:37 2024 +0800
Pipe: GC device2Measurements in PipeRealtimeEvent in time to avoid OOM when insertion is in high load (#14018)
(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,