Add message

apache · Jul 3, 2024 · 350e8d7 · 350e8d7
1 parent d495e56
commit 350e8d7
Show file tree

Hide file tree

Showing 2 changed files with 2 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
@@ -2280,7 +2280,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
                 .setCreateNamedStruct(structBuilder)
                 .build())
           } else {
-            withInfo(expr, struct.valExprs: _*)
+            withInfo(expr, "unsupported arguments for CreateNamedStruct", struct.valExprs: _*)
             None
           }
 

diff --git a/spark/src/test/scala/org/apache/comet/CometExpressionSuite.scala b/spark/src/test/scala/org/apache/comet/CometExpressionSuite.scala
@@ -1722,6 +1722,7 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
       }
     }
   }
+
   test("named_struct") {
     Seq(true, false).foreach { dictionaryEnabled =>
       withTempDir { dir =>
-Original file line number
+Diff line change
@@ Expand Up @@
           }
         }
       }
       test("named_struct") {
         Seq(true, false).foreach { dictionaryEnabled =>
           withTempDir { dir =>
@@ Expand Down @@