[ https://issues.apache.org/jira/browse/FLINK-21388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285801#comment-17285801 ]
Etienne Chauchot commented on FLINK-21388: ------------------------------------------ For the reference: [parquet DECIMAL logical type definition |https://github.com/apache/parquet-format/blob/master/LogicalTypes.md#decimal] > Parquet DECIMAL logical type is not properly supported in > ParquetSchemaConverter > -------------------------------------------------------------------------------- > > 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)