[jira] [Created] (FLINK-21388) Parquet DECIMAL logical type is not properly supported in ParquetInputFormat

[Shang Yuanchun (Jira)]

Etienne Chauchot created FLINK-21388:
----------------------------------------

             Summary: 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
            Reporter: Etienne Chauchot


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)