Skip to content

Commit 79159a1

Browse files
Yucai Yurxin
authored andcommitted
[SPARK-17635][SQL] Remove hardcode "agg_plan" in HashAggregateExec
## What changes were proposed in this pull request? "agg_plan" are hardcoded in HashAggregateExec, which have potential issue, so removing them. ## How was this patch tested? existing tests. Author: Yucai Yu <[email protected]> Closes #15199 from yucai/agg_plan.
1 parent a166196 commit 79159a1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -552,7 +552,7 @@ case class HashAggregateExec(
552552
} else {
553553
ctx.addMutableState(fastHashMapClassName, fastHashMapTerm,
554554
s"$fastHashMapTerm = new $fastHashMapClassName(" +
555-
s"agg_plan.getTaskMemoryManager(), agg_plan.getEmptyAggregationBuffer());")
555+
s"$thisPlan.getTaskMemoryManager(), $thisPlan.getEmptyAggregationBuffer());")
556556
ctx.addMutableState(
557557
"org.apache.spark.unsafe.KVIterator",
558558
iterTermForFastHashMap, "")

0 commit comments

Comments
 (0)