From 356fd859de057bd59dbd488b0b3e949500e8a3af Mon Sep 17 00:00:00 2001 From: lgbo-ustc Date: Tue, 23 Jul 2024 11:37:31 +0800 Subject: [PATCH] fixed tests --- .../execution/GlutenClickHouseTPCDSAbstractSuite.scala | 6 +----- .../GlutenClickHouseTPCDSParquetSortMergeJoinSuite.scala | 5 ++++- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseTPCDSAbstractSuite.scala b/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseTPCDSAbstractSuite.scala index f0712bf5af106..e3c296685a688 100644 --- a/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseTPCDSAbstractSuite.scala +++ b/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseTPCDSAbstractSuite.scala @@ -58,11 +58,7 @@ abstract class GlutenClickHouseTPCDSAbstractSuite Seq("q" + "%d".format(queryNum)) } val noFallBack = queryNum match { - case i if i == 10 || i == 16 || i == 35 || i == 45 || i == 94 => - // Q10 BroadcastHashJoin, ExistenceJoin - // Q16 ShuffledHashJoin, NOT condition - // Q35 BroadcastHashJoin, ExistenceJoin - // Q45 BroadcastHashJoin, ExistenceJoin + case i if i == 94 => // Q94 BroadcastHashJoin, LeftSemi, NOT condition (false, false) case other => (true, false) diff --git a/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseTPCDSParquetSortMergeJoinSuite.scala b/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseTPCDSParquetSortMergeJoinSuite.scala index 3f7816cb84ad0..3ec4e31a41096 100644 --- a/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseTPCDSParquetSortMergeJoinSuite.scala +++ b/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseTPCDSParquetSortMergeJoinSuite.scala @@ -23,12 +23,15 @@ import org.apache.spark.SparkConf class GlutenClickHouseTPCDSParquetSortMergeJoinSuite extends GlutenClickHouseTPCDSAbstractSuite { override protected def excludedTpcdsQueries: Set[String] = Set( - // fallback due to left semi/anti + // fallback due to left semi/anti/existence join "q8", + "q10", "q14a", "q14b", + "116", "q23a", "q23b", + "q35", "q38", "q51", "q69",