Skip to content

Commit faeb593

Browse files
author
Davies Liu
committed
Update TungstenAggregate.scala
remove over counting
1 parent 1076c75 commit faeb593

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TungstenAggregate.scala

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -319,9 +319,6 @@ case class TungstenAggregate(
319319
val metrics = TaskContext.get().taskMetrics()
320320
peakMemory.add(maxMemory)
321321
metrics.incPeakExecutionMemory(maxMemory)
322-
if (sorter != null) {
323-
spillSize.add(sorter.getSpillSize())
324-
}
325322

326323
if (sorter == null) {
327324
// not spilled

0 commit comments

Comments
 (0)