[
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 flink-formats
stale-major (was: Flink Flink-parquet Flink-table-api TableAPI flink-formats)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see this issues has been marked as
Major but is unassigned and neither itself nor its Sub-Tasks have been updated
for 60 days. I have gone ahead and added a "stale-major" to the issue". If this
ticket is a Major, please either assign yourself or give an update. Afterwards,
please remove the label or in 7 days the issue will be deprioritized.
> 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: Major
> Labels: Flink, Flink-parquet, Flink-table-api, TableAPI,
> flink-formats, stale-major
>
> 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)
