[jira] [Created] (FLINK-15919) MemoryManager shouldn't allow releasing more memory than reserved

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-15919) MemoryManager shouldn't allow releasing more memory than reserved

Shang Yuanchun (Jira)
Yu Li created FLINK-15919:
-----------------------------

             Summary: MemoryManager shouldn't allow releasing more memory than reserved
                 Key: FLINK-15919
                 URL: https://issues.apache.org/jira/browse/FLINK-15919
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Task
    Affects Versions: 1.10.0
            Reporter: Yu Li


Currently {{MemoryManager}} allows releasing more memory than reserved for an owner object, which could be reproduced by adding below test case into {{MemoryManagerTest}}:

{code}
        @Test
        public void testMemoryReleaseGuard() throws MemoryReservationException {
                Object owner = new Object();
                Object owner2 = new Object();

                long totalHeapMemorySize = memoryManager.getMemorySizeByType(MemoryType.HEAP);
                memoryManager.reserveMemory(owner, MemoryType.HEAP, PAGE_SIZE);
                memoryManager.reserveMemory(owner2, MemoryType.HEAP, PAGE_SIZE);
                memoryManager.releaseMemory(owner, MemoryType.HEAP, PAGE_SIZE);
                memoryManager.releaseMemory(owner, MemoryType.HEAP, PAGE_SIZE);
                long heapMemoryLeft = memoryManager.getMemorySizeByType(MemoryType.HEAP);
                assertEquals("Memory leak happens", totalHeapMemorySize - PAGE_SIZE, heapMemoryLeft);
        }
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)