Repository: spark
Updated Branches:
  refs/heads/branch-2.2 f66aabd7c -> 554700266


[SPARK-20471] Remove AggregateBenchmark testsuite warning: Two level hashmap is 
disabled but vectorized hashmap is enabled

What changes were proposed in this pull request?

remove  AggregateBenchmark testsuite warning:
such as '14:26:33.220 WARN 
org.apache.spark.sql.execution.aggregate.HashAggregateExec: Two level hashmap 
is disabled but vectorized hashmap is enabled.'

How was this patch tested?
unit tests: AggregateBenchmark
Modify the 'ignore function for 'test funtion

Author: caoxuewen <[email protected]>

Closes #17771 from heary-cao/AggregateBenchmark.

(cherry picked from commit ebff519c5ead31536e17a5b16cc47c2bf380d55e)
Signed-off-by: gatorsmile <[email protected]>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/55470026
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/55470026
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/55470026

Branch: refs/heads/branch-2.2
Commit: 554700266d2e3c3e504631c75eb6a086ce10a548
Parents: f66aabd
Author: caoxuewen <[email protected]>
Authored: Fri Apr 28 14:47:17 2017 -0700
Committer: gatorsmile <[email protected]>
Committed: Fri Apr 28 14:47:33 2017 -0700

----------------------------------------------------------------------
 .../spark/sql/execution/benchmark/AggregateBenchmark.scala      | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/55470026/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/AggregateBenchmark.scala
----------------------------------------------------------------------
diff --git 
a/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/AggregateBenchmark.scala
 
b/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/AggregateBenchmark.scala
index 8a2993b..8a798fb 100644
--- 
a/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/AggregateBenchmark.scala
+++ 
b/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/AggregateBenchmark.scala
@@ -107,6 +107,7 @@ class AggregateBenchmark extends BenchmarkBase {
     benchmark.addCase(s"codegen = T hashmap = F", numIters = 3) { iter =>
       sparkSession.conf.set("spark.sql.codegen.wholeStage", "true")
       sparkSession.conf.set("spark.sql.codegen.aggregate.map.twolevel.enable", 
"false")
+      
sparkSession.conf.set("spark.sql.codegen.aggregate.map.vectorized.enable", 
"false")
       f()
     }
 
@@ -148,6 +149,7 @@ class AggregateBenchmark extends BenchmarkBase {
     benchmark.addCase(s"codegen = T hashmap = F", numIters = 3) { iter =>
       sparkSession.conf.set("spark.sql.codegen.wholeStage", value = true)
       sparkSession.conf.set("spark.sql.codegen.aggregate.map.twolevel.enable", 
"false")
+      
sparkSession.conf.set("spark.sql.codegen.aggregate.map.vectorized.enable", 
"false")
       f()
     }
 
@@ -187,6 +189,7 @@ class AggregateBenchmark extends BenchmarkBase {
     benchmark.addCase(s"codegen = T hashmap = F", numIters = 3) { iter =>
       sparkSession.conf.set("spark.sql.codegen.wholeStage", "true")
       sparkSession.conf.set("spark.sql.codegen.aggregate.map.twolevel.enable", 
"false")
+      
sparkSession.conf.set("spark.sql.codegen.aggregate.map.vectorized.enable", 
"false")
       f()
     }
 
@@ -225,6 +228,7 @@ class AggregateBenchmark extends BenchmarkBase {
     benchmark.addCase(s"codegen = T hashmap = F") { iter =>
       sparkSession.conf.set("spark.sql.codegen.wholeStage", "true")
       sparkSession.conf.set("spark.sql.codegen.aggregate.map.twolevel.enable", 
"false")
+      
sparkSession.conf.set("spark.sql.codegen.aggregate.map.vectorized.enable", 
"false")
       f()
     }
 
@@ -273,6 +277,7 @@ class AggregateBenchmark extends BenchmarkBase {
     benchmark.addCase(s"codegen = T hashmap = F") { iter =>
       sparkSession.conf.set("spark.sql.codegen.wholeStage", "true")
       sparkSession.conf.set("spark.sql.codegen.aggregate.map.twolevel.enable", 
"false")
+      
sparkSession.conf.set("spark.sql.codegen.aggregate.map.vectorized.enable", 
"false")
       f()
     }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to