Skip to content

Commit 49b8135

Browse files
author
Davies Liu
committed
fix Spillable
1 parent ee6b9a4 commit 49b8135

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

core/src/main/java/org/apache/spark/memory/TaskMemoryManager.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -164,6 +164,9 @@ public long acquireExecutionMemory(long size, MemoryConsumer consumer) throws IO
164164
* Release N bytes of execution memory for a MemoryConsumer.
165165
*/
166166
public void releaseExecutionMemory(long size, MemoryConsumer consumer) {
167+
if (size == 0) {
168+
return;
169+
}
167170
synchronized (this) {
168171
if (consumers.containsKey(consumer)) {
169172
long old = consumers.get(consumer);

0 commit comments

Comments
 (0)