This is an automated email from the ASF dual-hosted git repository.
exmy pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 581c939800 [CH] Change enable_aggregate_if_to_filter to fasle (#9420)
581c939800 is described below
commit 581c9398003ce992fc097e0c7a171832ef05a182
Author: exmy <[email protected]>
AuthorDate: Mon Apr 28 09:37:17 2025 +0800
[CH] Change enable_aggregate_if_to_filter to fasle (#9420)
---
.../main/scala/org/apache/gluten/backendsapi/clickhouse/CHBackend.scala | 2 +-
.../scala/org/apache/gluten/execution/GlutenFunctionValidateSuite.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/backends-clickhouse/src/main/scala/org/apache/gluten/backendsapi/clickhouse/CHBackend.scala
b/backends-clickhouse/src/main/scala/org/apache/gluten/backendsapi/clickhouse/CHBackend.scala
index 1addfe23ea..64fd6155d5 100644
---
a/backends-clickhouse/src/main/scala/org/apache/gluten/backendsapi/clickhouse/CHBackend.scala
+++
b/backends-clickhouse/src/main/scala/org/apache/gluten/backendsapi/clickhouse/CHBackend.scala
@@ -429,7 +429,7 @@ object CHBackendSettings extends BackendSettingsApi with
Logging {
def enableAggregateIfToFilter(): Boolean = {
SparkEnv.get.conf.getBoolean(
CHConfig.runtimeConfig("enable_aggregate_if_to_filter"),
- defaultValue = true
+ defaultValue = false
)
}
diff --git
a/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenFunctionValidateSuite.scala
b/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenFunctionValidateSuite.scala
index 2250f8bfe3..194fabb855 100644
---
a/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenFunctionValidateSuite.scala
+++
b/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenFunctionValidateSuite.scala
@@ -1353,7 +1353,7 @@ class GlutenFunctionValidateSuite extends
GlutenClickHouseWholeStageTransformerS
}
}
- test("Test rewrite aggregate if to aggregate with filter") {
+ ignore("Test rewrite aggregate if to aggregate with filter") {
val sql = "select sum(if(id % 2=0, id, null)), count(if(id % 2 = 0, 1,
null)), " +
"avg(if(id % 4 = 0, id, null)), sum(if(id % 3 = 0, id, 0)) from
range(10)"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
