From e96ef3c54629261e47639aa69aaf5a31324f4c63 Mon Sep 17 00:00:00 2001 From: huanglong Date: Tue, 15 Oct 2024 14:48:56 +0800 Subject: [PATCH] fix resin UT --- .../catalyst/optimizer/CombineJoinedAggregatesSuite.scala | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/omnioperator/omniop-spark-extension/java/src/test/scala/org/apache/spark/sql/catalyst/optimizer/CombineJoinedAggregatesSuite.scala b/omnioperator/omniop-spark-extension/java/src/test/scala/org/apache/spark/sql/catalyst/optimizer/CombineJoinedAggregatesSuite.scala index a55fcd437..69a3d8430 100644 --- a/omnioperator/omniop-spark-extension/java/src/test/scala/org/apache/spark/sql/catalyst/optimizer/CombineJoinedAggregatesSuite.scala +++ b/omnioperator/omniop-spark-extension/java/src/test/scala/org/apache/spark/sql/catalyst/optimizer/CombineJoinedAggregatesSuite.scala @@ -18,6 +18,7 @@ package org.apache.spark.sql.catalyst.optimizer +import org.apache.spark.SparkConf import org.apache.spark.sql.DataFrame import org.apache.spark.sql.execution.{ColumnarSparkPlanTest, SparkPlan} @@ -27,10 +28,12 @@ class CombineJoinedAggregatesSuite extends ColumnarSparkPlanTest { private var dfForResin: DataFrame = _ + override def sparkConf: SparkConf = super.sparkConf + .set("spark.sql.execution.combineJoinedAggregates.enabled", "true") + override def beforeAll(): Unit = { super.beforeAll() - spark.conf.set("spark.sql.execution.combineJoinedAggregates.enabled", true) dfForResin = Seq[(Boolean, Short, Int, Long, Float, Double, String)]( (true, 10.toShort, 100, 1000L, 1.5f, 10.5, "aaa"), (false, 20.toShort, 200, 2000L, 2.5f, 20.5, "bbb"), -- Gitee