diff options
| author | Yucai Yu <yucai.yu@intel.com> | 2016-09-22 17:22:56 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-09-22 17:22:56 -0700 |
| commit | 79159a1e87f19fb08a36857fc30b600ee7fdc52b (patch) | |
| tree | d836f0137e46a19b823fc85399e600a07343ae74 | |
| parent | a1661968310de35e710e3b6784f63a77c44453fc (diff) | |
| download | spark-79159a1e87f19fb08a36857fc30b600ee7fdc52b.tar.gz spark-79159a1e87f19fb08a36857fc30b600ee7fdc52b.tar.bz2 spark-79159a1e87f19fb08a36857fc30b600ee7fdc52b.zip | |
[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 <yucai.yu@intel.com>
Closes #15199 from yucai/agg_plan.
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala index 59e132dfb2..06199ef3e8 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala @@ -552,7 +552,7 @@ case class HashAggregateExec( } else { ctx.addMutableState(fastHashMapClassName, fastHashMapTerm, s"$fastHashMapTerm = new $fastHashMapClassName(" + - s"agg_plan.getTaskMemoryManager(), agg_plan.getEmptyAggregationBuffer());") + s"$thisPlan.getTaskMemoryManager(), $thisPlan.getEmptyAggregationBuffer());") ctx.addMutableState( "org.apache.spark.unsafe.KVIterator", iterTermForFastHashMap, "") |