From e0e82493653417d3eae0f45d04c4199240307b13 Mon Sep 17 00:00:00 2001 From: liuneng <1398775315@qq.com> Date: Fri, 3 Nov 2023 16:35:10 +0800 Subject: [PATCH] fix ut failed --- .../execution/adaptive/GlutenAdaptiveQueryExecSuite.scala | 6 ++++-- .../execution/adaptive/GlutenAdaptiveQueryExecSuite.scala | 6 ++++-- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/gluten-ut/spark32/src/test/scala/org/apache/spark/sql/execution/adaptive/GlutenAdaptiveQueryExecSuite.scala b/gluten-ut/spark32/src/test/scala/org/apache/spark/sql/execution/adaptive/GlutenAdaptiveQueryExecSuite.scala index db78728790f73..10d8b5ba7949c 100644 --- a/gluten-ut/spark32/src/test/scala/org/apache/spark/sql/execution/adaptive/GlutenAdaptiveQueryExecSuite.scala +++ b/gluten-ut/spark32/src/test/scala/org/apache/spark/sql/execution/adaptive/GlutenAdaptiveQueryExecSuite.scala @@ -438,8 +438,10 @@ class GlutenAdaptiveQueryExecSuite extends AdaptiveQueryExecSuite with GlutenSQL test("gluten Exchange reuse") { withSQLConf( SQLConf.ADAPTIVE_EXECUTION_ENABLED.key -> "true", - SQLConf.AUTO_BROADCASTJOIN_THRESHOLD.key -> "100", - SQLConf.SHUFFLE_PARTITIONS.key -> "5") { + // magic threshold, ch backend has two bhj when threshold is 100 + SQLConf.AUTO_BROADCASTJOIN_THRESHOLD.key -> "90", + SQLConf.SHUFFLE_PARTITIONS.key -> "5" + ) { val (plan, adaptivePlan) = runAdaptiveAndVerifyResult( "SELECT value FROM testData join testData2 ON key = a " + "join (SELECT value v from testData join testData3 ON key = a) on value = v") diff --git a/gluten-ut/spark33/src/test/scala/org/apache/spark/sql/execution/adaptive/GlutenAdaptiveQueryExecSuite.scala b/gluten-ut/spark33/src/test/scala/org/apache/spark/sql/execution/adaptive/GlutenAdaptiveQueryExecSuite.scala index 9a9dd77e4364e..b2d16339d577a 100644 --- a/gluten-ut/spark33/src/test/scala/org/apache/spark/sql/execution/adaptive/GlutenAdaptiveQueryExecSuite.scala +++ b/gluten-ut/spark33/src/test/scala/org/apache/spark/sql/execution/adaptive/GlutenAdaptiveQueryExecSuite.scala @@ -438,8 +438,10 @@ class GlutenAdaptiveQueryExecSuite extends AdaptiveQueryExecSuite with GlutenSQL test("gluten Exchange reuse") { withSQLConf( SQLConf.ADAPTIVE_EXECUTION_ENABLED.key -> "true", - SQLConf.AUTO_BROADCASTJOIN_THRESHOLD.key -> "100", - SQLConf.SHUFFLE_PARTITIONS.key -> "5") { + // magic threshold, ch backend has two bhj when threshold is 100 + SQLConf.AUTO_BROADCASTJOIN_THRESHOLD.key -> "90", + SQLConf.SHUFFLE_PARTITIONS.key -> "5" + ) { val (plan, adaptivePlan) = runAdaptiveAndVerifyResult( "SELECT value FROM testData join testData2 ON key = a " + "join (SELECT value v from testData join testData3 ON key = a) on value = v")