From 944d5b1053c6890fd83d6d6979b8d91fbead5fa8 Mon Sep 17 00:00:00 2001 From: Liang-Chi Hsieh Date: Mon, 19 Aug 2024 16:46:19 -0700 Subject: [PATCH] test --- .../test/scala/org/apache/comet/exec/CometJoinSuite.scala | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/spark/src/test/scala/org/apache/comet/exec/CometJoinSuite.scala b/spark/src/test/scala/org/apache/comet/exec/CometJoinSuite.scala index ace375bc17..0879e278d2 100644 --- a/spark/src/test/scala/org/apache/comet/exec/CometJoinSuite.scala +++ b/spark/src/test/scala/org/apache/comet/exec/CometJoinSuite.scala @@ -42,6 +42,7 @@ class CometJoinSuite extends CometTestBase { } } + /* test("join - self join") { val df1 = testData.select(testData("key")).as("df1") val df2 = testData.select(testData("key")).as("df2") @@ -335,10 +336,10 @@ class CometJoinSuite extends CometTestBase { } } } + */ test("SortMergeJoin with join filter") { withSQLConf( - CometConf.COMET_EXEC_SORT_MERGE_JOIN_DISABLED.key -> "true", SQLConf.ADAPTIVE_AUTO_BROADCASTJOIN_THRESHOLD.key -> "-1", SQLConf.AUTO_BROADCASTJOIN_THRESHOLD.key -> "-1") { withParquetTable((0 until 10).map(i => (i, i % 5)), "tbl_a") { @@ -372,9 +373,10 @@ class CometJoinSuite extends CometTestBase { val df6 = sql( "SELECT * FROM tbl_a FULL JOIN tbl_b ON tbl_a._2 = tbl_b._1 " + - "AND tbl_a._1 > tbl_b._2") + "AND tbl_a._1 > tbl_b._2 ORDER BY tbl_a._1, tbl_a._2") df6.explain() - checkSparkAnswer(df6) + df6.show(100) + // checkSparkAnswer(df6) /* val df7 = sql(