File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
spark/src/main/scala/org/apache Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -68,8 +68,8 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
6868 case dt if isTimestampNTZType(dt) => true
6969 case s : StructType if allowComplex =>
7070 s.fields.map(_.dataType).forall(supportedDataType(_, allowComplex))
71- case a : ArrayType if allowComplex =>
72- supportedDataType(a.elementType)
71+ // case a: ArrayType if allowComplex =>
72+ // supportedDataType(a.elementType)
7373 case dt =>
7474 emitWarning(s " unsupported Spark data type: $dt" )
7575 false
Original file line number Diff line number Diff line change @@ -489,7 +489,7 @@ object CometScanExec extends DataTypeSupport {
489489 // TODO add map
490490 dt match {
491491 case s : StructType => s.fields.map(_.dataType).forall(isTypeSupported)
492- case a : ArrayType => isTypeSupported(a.elementType)
492+ // case a: ArrayType => isTypeSupported(a.elementType)
493493 case _ => false
494494 }
495495 } else {
You can’t perform that action at this time.
0 commit comments