This is an automated email from the ASF dual-hosted git repository.
agrove 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 d52038e8 fix regression (#1259)
d52038e8 is described below
commit d52038e883e2c1d06e32b96cb02de4964d2ed2d2
Author: Andy Grove <[email protected]>
AuthorDate: Fri Jan 10 11:31:48 2025 -0700
fix regression (#1259)
---
spark/src/test/scala/org/apache/comet/exec/CometAggregateSuite.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/spark/src/test/scala/org/apache/comet/exec/CometAggregateSuite.scala
b/spark/src/test/scala/org/apache/comet/exec/CometAggregateSuite.scala
index 8170230b..615ca591 100644
--- a/spark/src/test/scala/org/apache/comet/exec/CometAggregateSuite.scala
+++ b/spark/src/test/scala/org/apache/comet/exec/CometAggregateSuite.scala
@@ -108,7 +108,7 @@ class CometAggregateSuite extends CometTestBase with
AdaptiveSparkPlanHelper {
val cometShuffles = collect(df2.queryExecution.executedPlan) {
case _: CometShuffleExchangeExec => true
}
- if (shuffleMode == "jvm") {
+ if (shuffleMode == "jvm" || shuffleMode == "auto") {
assert(cometShuffles.length == 1)
} else {
// we fall back to Spark for shuffle because we do not support
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
