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 fb4c78a0 Show reason for falling back to Spark when SMJ with join
condition is not enabled (#956)
fb4c78a0 is described below
commit fb4c78a0b43d8be12e1af0bc66174d3ff583b11b
Author: Andy Grove <[email protected]>
AuthorDate: Fri Sep 20 13:49:35 2024 -0600
Show reason for falling back to Spark when SMJ with join condition is not
enabled (#956)
---
spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
index 0ee05d82..4fde2fd1 100644
--- a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
+++ b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
@@ -2976,7 +2976,10 @@ object QueryPlanSerde extends Logging with
ShimQueryPlanSerde with CometExprShim
if (join.condition.isDefined &&
!CometConf.COMET_EXEC_SORT_MERGE_JOIN_WITH_JOIN_FILTER_ENABLED
.get(conf)) {
- withInfo(join, join.condition.get)
+ withInfo(
+ join,
+
s"${CometConf.COMET_EXEC_SORT_MERGE_JOIN_WITH_JOIN_FILTER_ENABLED.key} is not
enabled",
+ join.condition.get)
return None
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
