diff --git a/core/src/main/java/org/apache/spark/memory/TaskMemoryManager.java b/core/src/main/java/org/apache/spark/memory/TaskMemoryManager.java index 6b7d9aa20fc164763e947512df2e9d93b4a03fce..2796114fc545a005a93b2606382ddd9e0ed9994b 100644 --- a/core/src/main/java/org/apache/spark/memory/TaskMemoryManager.java +++ b/core/src/main/java/org/apache/spark/memory/TaskMemoryManager.java @@ -114,7 +114,7 @@ public class TaskMemoryManager { /** * The amount of memory that is acquired but not used. */ - private long acquiredButNotUsed = 0L; + private volatile long acquiredButNotUsed = 0L; /** * Construct a new TaskMemoryManager.