(datafusion-comet) branch main updated: Show reason for falling back to Spark when SMJ with join condition is not enabled (#956)

[ag...@apache.org]

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 <ag...@apache.org>
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: commits-unsubscribe@datafusion.apache.org
For additional commands, e-mail: commits-help@datafusion.apache.org