File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
spark/src/test/scala/org/apache/comet/exec Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -21,12 +21,14 @@ package org.apache.comet.exec
2121
2222import org .scalactic .source .Position
2323import org .scalatest .Tag
24+
2425import org .apache .spark .sql .CometTestBase
2526import org .apache .spark .sql .catalyst .TableIdentifier
2627import org .apache .spark .sql .catalyst .analysis .UnresolvedRelation
2728import org .apache .spark .sql .comet .{CometBroadcastExchangeExec , CometBroadcastHashJoinExec }
2829import org .apache .spark .sql .internal .SQLConf
2930import org .apache .spark .sql .types .Decimal
31+
3032import org .apache .comet .CometConf
3133import org .apache .comet .CometConf .COMET_EXEC_SORT_MERGE_JOIN_WITH_JOIN_FILTER_ENABLED
3234import org .apache .comet .CometSparkSessionExtensions .isSpark34Plus
@@ -295,8 +297,7 @@ class CometJoinSuite extends CometTestBase {
295297 withSQLConf(
296298 CometConf .COMET_EXEC_SORT_MERGE_JOIN_WITH_JOIN_FILTER_ENABLED .key -> " true" ,
297299 SQLConf .ADAPTIVE_AUTO_BROADCASTJOIN_THRESHOLD .key -> " -1" ,
298- SQLConf .AUTO_BROADCASTJOIN_THRESHOLD .key -> " -1"
299- ) {
300+ SQLConf .AUTO_BROADCASTJOIN_THRESHOLD .key -> " -1" ) {
300301 withParquetTable((0 until 10 ).map(i => (i, i % 5 )), " tbl_a" ) {
301302 withParquetTable((0 until 10 ).map(i => (i % 10 , i + 2 )), " tbl_b" ) {
302303 val df1 = sql(" SELECT * FROM tbl_a JOIN tbl_b ON tbl_a._2 = tbl_b._1" )
You can’t perform that action at this time.
0 commit comments