Skip to content

Commit 12ed084

Browse files
committed
Fix TaskResultGetterSuite.
1 parent 7f28910 commit 12ed084

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

core/src/main/scala/org/apache/spark/scheduler/TaskResultGetter.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,7 @@ private[spark] class TaskResultGetter(sparkEnv: SparkEnv, scheduler: TaskSchedul
7878
}
7979
val deserializedResult = serializer.get().deserialize[DirectTaskResult[_]](
8080
serializedTaskResult.get)
81+
sparkEnv.blockManager.release(blockId)
8182
sparkEnv.blockManager.master.removeBlock(blockId)
8283
(deserializedResult, size)
8384
}

0 commit comments

Comments
 (0)