fix: synchronized method in ThreadSafeMemoryReservationManager #16950

shizy818 · web-flow · commit 910a623f91dc · 2025-12-25T18:23:00.000+08:00
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
@@ -52,12 +52,12 @@ public synchronized void releaseAllReservedMemory() {
   }
 
   @Override
-  public Pair<Long, Long> releaseMemoryVirtually(final long size) {
+  public synchronized Pair<Long, Long> 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);
   }

Original file line number	Diff line number	Diff line change
`@@ -52,12 +52,12 @@ public synchronized void releaseAllReservedMemory() {`
`52`	`52`	`}`
`53`	`53`
`54`	`54`	`@Override`
`55`		`- public Pair<Long, Long> releaseMemoryVirtually(final long size) {`
	`55`	`+ public synchronized Pair<Long, Long> releaseMemoryVirtually(final long size) {`
`56`	`56`	`return super.releaseMemoryVirtually(size);`
`57`	`57`	`}`
`58`	`58`
`59`	`59`	`@Override`
`60`		`- public void reserveMemoryVirtually(`
	`60`	`+ public synchronized void reserveMemoryVirtually(`
`61`	`61`	`final long bytesToBeReserved, final long bytesAlreadyReserved) {`
`62`	`62`	`super.reserveMemoryVirtually(bytesToBeReserved, bytesAlreadyReserved);`
`63`	`63`	`}`