From 350e8d7138457330bcf17433faee8218663ef3e7 Mon Sep 17 00:00:00 2001 From: Emil Ejbyfeldt Date: Wed, 3 Jul 2024 14:39:45 +0200 Subject: [PATCH] Add message --- .../src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala | 2 +- .../src/test/scala/org/apache/comet/CometExpressionSuite.scala | 1 + 2 files changed, 2 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 40ef64819..294978036 100644 --- 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 index 8b4ab4331..946ffa423 100644 --- 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 =>