@@ -53,7 +53,7 @@ public class MemoryManageTest {
53
53
protected static MemoryManager memoryManager ;
54
54
protected static MemoryPool query1MemoryPool ;
55
55
protected static MemoryPool query1Task1MemoryPool ;
56
- protected static String QUERY1_TASK1_THREAD_NAME = "QUERY1-THREAD-1 " ;
56
+ protected static String QUERY1_TASK1_THREAD_NAME = "main " ;
57
57
protected static MemoryPool query1Task2MemoryPool ;
58
58
protected static String QUERY1_TASK2_THREAD_NAME = "QUERY1-THREAD-2" ;
59
59
protected static MemoryPool query1Task1Operator1MemoryPool ;
@@ -149,7 +149,9 @@ public void testReleaseMemoryWithTask() {
149
149
ByteBuf memoryBlock = (ByteBuf ) query1Task1Operator1MemoryPool .requireMemory (requireBytes );
150
150
Assert .assertNotNull (memoryBlock );
151
151
Assert .assertEquals (requireBytes , memoryBlock .capacity ());
152
- query1Task1MemoryPool .releaseSelf ("Test release by hand" , false );
152
+ memoryManager .getCorrespondingTaskMemoryPool (QUERY1_TASK1_THREAD_NAME )
153
+ .releaseSelf ("Test release by hand" , false );
154
+ Assert .assertNull (memoryManager .getCorrespondingTaskMemoryPool (QUERY1_TASK1_THREAD_NAME ));
153
155
Assert .assertEquals (1 , query1MemoryPool .getChildrenCount ());
154
156
Assert .assertEquals (0 , query1MemoryPool .getAllocatedBytes ());
155
157
Assert .assertEquals (0 , query1MemoryPool .getUsedBytes ());
0 commit comments