[iotdb] branch rel/1.1 updated: [To rel/1.1] Fix potential resource leak in Memory Pool

[jackietien]

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

jackietien pushed a commit to branch rel/1.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/1.1 by this push:
     new ea17746e33 [To rel/1.1] Fix potential resource leak in Memory Pool
ea17746e33 is described below

commit ea17746e33a18b2bb07b82d6efe388354a28a1e6
Author: Jackie Tien <jackietie...@gmail.com>
AuthorDate: Mon Apr 17 07:11:21 2023 +0800

    [To rel/1.1] Fix potential resource leak in Memory Pool
---
 .../apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
index ca1a42746b..1be2d7fbd5 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
@@ -321,5 +321,9 @@ public class SharedTsBlockQueue {
               bufferRetainedSizeInBytes);
       bufferRetainedSizeInBytes = 0;
     }
+    localMemoryManager
+        .getQueryPool()
+        .clearMemoryReservationMap(
+            localFragmentInstanceId.getQueryId(), fullFragmentInstanceId, 
localPlanNodeId);
   }
 }