Skip to content

Commit

Permalink
test: Restore one test in CometExecSuite by adding COMET_SHUFFLE_MODE…
Browse files Browse the repository at this point in the history
… config (#1087)
  • Loading branch information
viirya authored Nov 15, 2024
1 parent 2c832b4 commit 7cec285
Showing 1 changed file with 12 additions and 10 deletions.
22 changes: 12 additions & 10 deletions spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala
Original file line number Diff line number Diff line change
Expand Up @@ -119,17 +119,19 @@ class CometExecSuite extends CometTestBase {
}

test("ShuffleQueryStageExec could be direct child node of CometBroadcastExchangeExec") {
val table = "src"
withTable(table) {
withView("lv_noalias") {
sql(s"CREATE TABLE $table (key INT, value STRING) USING PARQUET")
sql(s"INSERT INTO $table VALUES(238, 'val_238')")
withSQLConf(CometConf.COMET_SHUFFLE_MODE.key -> "jvm") {
val table = "src"
withTable(table) {
withView("lv_noalias") {
sql(s"CREATE TABLE $table (key INT, value STRING) USING PARQUET")
sql(s"INSERT INTO $table VALUES(238, 'val_238')")

sql(
"CREATE VIEW lv_noalias AS SELECT myTab.* FROM src " +
"LATERAL VIEW explode(map('key1', 100, 'key2', 200)) myTab LIMIT 2")
val df = sql("SELECT * FROM lv_noalias a JOIN lv_noalias b ON a.key=b.key");
checkSparkAnswer(df)
sql(
"CREATE VIEW lv_noalias AS SELECT myTab.* FROM src " +
"LATERAL VIEW explode(map('key1', 100, 'key2', 200)) myTab LIMIT 2")
val df = sql("SELECT * FROM lv_noalias a JOIN lv_noalias b ON a.key=b.key");
checkSparkAnswer(df)
}
}
}
}
Expand Down

0 comments on commit 7cec285

Please sign in to comment.