[iotdb] branch reservationQueue created (now 57a741e02c7)

[la...@apache.org]

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

lancelly pushed a change to branch reservationQueue
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 57a741e02c7 fix

This branch includes the following new commits:

     new 57a741e02c7 fix

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: fix

[la...@apache.org]

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

lancelly pushed a commit to branch reservationQueue
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 57a741e02c7f8773ff8a8362fae49ca9a4c937ba
Author: lancelly <14...@qq.com>
AuthorDate: Thu Sep 14 11:27:50 2023 +0800

    fix
---
 .../org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java
index 7aac8447610..936a4cbcb27 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java
@@ -334,6 +334,7 @@ public class MemoryPool {
       MemoryReservationFuture<Void> future = iterator.next();
       synchronized (future) {
         if (future.isCancelled() || future.isDone()) {
+          iterator.remove();
           continue;
         }
         long bytesToReserve = future.getBytesToReserve();