This is an automated email from the ASF dual-hosted git repository.
viirya pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git
The following commit(s) were added to refs/heads/main by this push:
new 7cec2858 test: Restore one test in CometExecSuite by adding
COMET_SHUFFLE_MODE config (#1087)
7cec2858 is described below
commit 7cec28588345c2d240119e0500e2cacc1fd8a788
Author: Liang-Chi Hsieh <[email protected]>
AuthorDate: Thu Nov 14 16:47:57 2024 -0800
test: Restore one test in CometExecSuite by adding COMET_SHUFFLE_MODE
config (#1087)
---
.../org/apache/comet/exec/CometExecSuite.scala | 22 ++++++++++++----------
1 file changed, 12 insertions(+), 10 deletions(-)
diff --git a/spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala
b/spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala
index 99007d0c..d262e83f 100644
--- a/spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala
+++ b/spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala
@@ -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)
+ }
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
