[
https://issues.apache.org/jira/browse/FLINK-28756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28756:
-----------------------------------
Labels: Flink Flink-parquet Flink-table-api TableAPI
auto-deprioritized-major flink-formats (was: Flink Flink-parquet
Flink-table-api TableAPI flink-formats stale-major)
Priority: Minor (was: Major)
This issue was labeled "stale-major" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Major, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> Can't write nested object to parquet flink 1.15.1
> -------------------------------------------------
>
> Key: FLINK-28756
> URL: https://issues.apache.org/jira/browse/FLINK-28756
> Project: Flink
> Issue Type: New Feature
> Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table
> SQL / API
> Affects Versions: 1.15.1
> Environment: Local running and Flink on docker
> Reporter: Jonathan diamant
> Priority: Minor
> Labels: Flink, Flink-parquet, Flink-table-api, TableAPI,
> auto-deprioritized-major, flink-formats
>
> Hey, I'm trying to write nested objects to parquet files with Table api (by
> specifying the schema). I did manage to write flattened objects to parquet
> files. The objects I want to write contain array of objects. The schema I
> used is
>
> {code:java}
> DataTypes. ARRAY(DataTypes.ROW({code}
> {code:java}
> DataTypes.FIELD(...),...)){code}
>
> When I tried to run it locally I got the exception:
>
> empty fields are illegal, the field should be ommited completely instead
>
> And when I debugged the code I saw that the method
> {code:java}
> Public void write(Array Data array Data, int ordinal) {code}
>
>
> In the class RowWriter in ParquetRowDataWriter is not implemented and thus
> the content of the array cannot be written.
>
> I have wondered if the method can be implemented or what it takes to
> implement it.
> (I have thought that this can be solved by call the write(RowData row) method
> of the same class with the correct parameters from the arrayData).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
