Show reason for falling back to Spark when SMJ with join condition is…

… not enabled
apache · Sep 20, 2024 · 56d321d · 56d321d
1 parent fa275f1
commit 56d321d
Showing 1 changed file with 4 additions and 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
@@ -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
         }