Update spark/src/main/scala/org/apache/comet/serde/CometScalarSubquery.scala

andygrove · martin-g · web-flow · commit 0e64efce3e21 · 2025-11-18T12:58:10.000-07:00
Co-authored-by: Martin Grigorov &lt;martin-g@users.noreply.github.com&gt;
diff --git a/spark/src/main/scala/org/apache/comet/serde/CometScalarSubquery.scala b/spark/src/main/scala/org/apache/comet/serde/CometScalarSubquery.scala
@@ -33,7 +33,7 @@ object CometScalarSubquery extends CometExpressionSerde[ScalarSubquery] {
     if (supportedDataType(expr.dataType)) {
       val dataType = serializeDataType(expr.dataType)
       if (dataType.isEmpty) {
-        withInfo(expr, s"Scalar subquery returns unsupported datatype ${expr.dataType}")
+        withInfo(expr, s"Failed to serialize datatype ${expr.dataType} for scalar subquery")
         return None
       }
 

Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,7 @@ object CometScalarSubquery extends CometExpressionSerde[ScalarSubquery] {`
`33`	`33`	`if (supportedDataType(expr.dataType)) {`
`34`	`34`	`val dataType = serializeDataType(expr.dataType)`
`35`	`35`	`if (dataType.isEmpty) {`
`36`		`- withInfo(expr, s"Scalar subquery returns unsupported datatype ${expr.dataType}")`
	`36`	`+ withInfo(expr, s"Failed to serialize datatype ${expr.dataType} for scalar subquery")`
`37`	`37`	`return None`
`38`	`38`	`}`
`39`	`39`