diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/memory/ThreadSafeMemoryReservationManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/memory/ThreadSafeMemoryReservationManager.java index 190c4fedd5c6..d167eae354ff 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/memory/ThreadSafeMemoryReservationManager.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/memory/ThreadSafeMemoryReservationManager.java @@ -52,12 +52,12 @@ public synchronized void releaseAllReservedMemory() { } @Override - public Pair releaseMemoryVirtually(final long size) { + public synchronized Pair releaseMemoryVirtually(final long size) { return super.releaseMemoryVirtually(size); } @Override - public void reserveMemoryVirtually( + public synchronized void reserveMemoryVirtually( final long bytesToBeReserved, final long bytesAlreadyReserved) { super.reserveMemoryVirtually(bytesToBeReserved, bytesAlreadyReserved); }