Re: Reading Parquet file with array of structs cause error

day, November 15, 2022 at 3:39 PM >> *To: *Benenson, Michael >> *Cc: *user@flink.apache.org , Deshpande, Omkar < >> omkar_deshpa...@intuit.com>, Vora, Jainik >> *Subject: *Re: Reading Parquet file with array of structs cause error >> >> This email is from an external s

Re: Reading Parquet file with array of structs cause error

ate Jira? > > > > > > *From: *Jing Ge > *Date: *Tuesday, November 15, 2022 at 3:39 PM > *To: *Benenson, Michael > *Cc: *user@flink.apache.org , Deshpande, Omkar < > omkar_deshpa...@intuit.com>, Vora, Jainik > *Subject: *Re: Reading Parquet file with arra

Re: Reading Parquet file with array of structs cause error

, Vora, Jainik Subject: Re: Reading Parquet file with array of structs cause error This email is from an external sender. Hi Michael, Currently, ParquetColumnarRowInputFormat does not support schemas with nested columns. If your parquet file stores Avro records. You might want to try e.g.

Re: Reading Parquet file with array of structs cause error

Hi Michael, Currently, ParquetColumnarRowInputFormat does not support schemas with nested columns. If your parquet file stores Avro records. You might want to try e.g. Avro Generic record[1]. [1] https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/connectors/datastream/formats/parquet