We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1440c17 commit 698fe3eCopy full SHA for 698fe3e
spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
@@ -69,7 +69,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
69
case s: StructType if allowComplex =>
70
s.fields.map(_.dataType).forall(supportedDataType(_, allowComplex))
71
case a: ArrayType if allowComplex =>
72
- supportedDataType(a.elementType)
+ supportedDataType(a.elementType, allowComplex)
73
case dt =>
74
emitWarning(s"unsupported Spark data type: $dt")
75
false
0 commit comments