File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed
spark/src/main/scala/org/apache/comet/serde Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -843,10 +843,12 @@ object QueryPlanSerde extends Logging with CometExprShim {
843843 case Literal (value, dataType)
844844 if supportedDataType(
845845 dataType,
846- allowComplex = value == null || Seq (
847- CometConf .SCAN_NATIVE_ICEBERG_COMPAT ,
848- CometConf .SCAN_NATIVE_DATAFUSION ).contains(
849- CometConf .COMET_NATIVE_SCAN_IMPL .get())) =>
846+ allowComplex = value == null ||
847+ // Nested literal support for native reader
848+ // can be tracked https://github.com/apache/datafusion-comet/issues/1937
849+ (Seq (CometConf .SCAN_NATIVE_ICEBERG_COMPAT , CometConf .SCAN_NATIVE_DATAFUSION )
850+ .contains(CometConf .COMET_NATIVE_SCAN_IMPL .get()) && dataType
851+ .isInstanceOf [ArrayType ])) =>
850852 val exprBuilder = ExprOuterClass .Literal .newBuilder()
851853
852854 if (value == null ) {
You can’t perform that action at this time.
0 commit comments