You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/17 10:39:00 UTC
[jira] [Assigned] (FLINK-21388) Parquet DECIMAL logical type is not
properly supported in ParquetInputFormat
[ https://issues.apache.org/jira/browse/FLINK-21388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robert Metzger reassigned FLINK-21388:
--------------------------------------
Assignee: Etienne Chauchot
> Parquet DECIMAL logical type is not properly supported in ParquetInputFormat
> ----------------------------------------------------------------------------
>
> Key: FLINK-21388
> URL: https://issues.apache.org/jira/browse/FLINK-21388
> Project: Flink
> Issue Type: Bug
> Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / Ecosystem
> Reporter: Etienne Chauchot
> Assignee: Etienne Chauchot
> Priority: Major
>
> For a parquet field such as this one
> {code:java}
> optional int32 ss_wholesale_cost (DECIMAL(7,2));{code}
> _ParquetSchemaConverter_ raises the exception:
> {code:java}
> Unsupported original type : DECIMAL for primitive type INT32{code}
> whereas it should be mapped to flink _DECIMAL_ Datatype (_BIG_DEC_ type information) owing to https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connectors/formats/parquet.html#data-type-mapping
> and https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/types.html#old-planner
--
This message was sent by Atlassian Jira
(v8.3.4#803005)