This is an automated email from the ASF dual-hosted git repository. Caideyipi pushed a commit to branch disruptor in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6d591e97fc7de53bbcfb4539b4fab6a8add1dc13 Author: Caideyipi <[email protected]> AuthorDate: Mon Apr 27 09:56:23 2026 +0800 fix --- .../dataregion/realtime/listener/PipeInsertionDataNodeListener.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/listener/PipeInsertionDataNodeListener.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/listener/PipeInsertionDataNodeListener.java index 72d76bf5b2f..fded546d87d 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/listener/PipeInsertionDataNodeListener.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/listener/PipeInsertionDataNodeListener.java @@ -93,7 +93,7 @@ public class PipeInsertionDataNodeListener { // The removed assigner will is the same as the one referenced by the variable `assigner` dataRegionId2Assigner.remove(dataRegionId); // This will help to release the memory occupied by the assigner - assigner.close(); + assignerToClose = assigner; } }
