[jira] [Closed] (FLINK-14046) DDL property 'format.fields.#.type' should ignore case

["Jark Wu (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-14046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jark Wu closed FLINK-14046.
---------------------------
    Fix Version/s:     (was: 1.11.0)
       Resolution: Won't Fix

Close this issue as users don't need to fill {{format.schema.#.field}} properties anymore in 1.10, the format will derive schema from table's schema by default.

> DDL property 'format.fields.#.type' should ignore case 
> -------------------------------------------------------
>
>                 Key: FLINK-14046
>                 URL: https://issues.apache.org/jira/browse/FLINK-14046
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table SQL / API
>    Affects Versions: 1.9.0
>            Reporter: hailong wang
>            Priority: Minor
>              Labels: pull-request-available
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> When define DDL as follow:
> {code:java}
> create table RubberOrders(
>   b int
> ) with (
>  'connector.type' = 'filesystem',
>  'format.type' = 'csv',                        
>  'connector.path' = '##',
>  'format.fields.0.name' = 'b',
>  'format.fields.0.type' = 'int'
> )
> {code}
> It has an exception:
> {code:java}
> Could not parse type information at position 0: Unsupported type: int
> Input type string: int 
> at org.apache.flink.table.utils.TypeStringUtils$TokenConverter.parsingError(TypeStringUtils.java:491) at org.apache.flink.table.utils.TypeStringUtils$TokenConverter.convertType(TypeStringUtils.java:318) at org.apache.flink.table.utils.TypeStringUtils$TokenConverter.convert(TypeStringUtils.java:261) at org.apache.flink.table.utils.TypeStringUtils.readTypeInfo(TypeStringUtils.java:169) at org.apache.flink.table.descriptors.DescriptorProperties.lambda$validateType$32(DescriptorProperties.java:1149) at org.apache.flink.table.descriptors.DescriptorProperties.validateOptional(DescriptorProperties.java:1357) at org.apache.flink.table.descriptors.DescriptorProperties.validateType(DescriptorProperties.java:1143) at org.apache.flink.table.descriptors.DescriptorProperties.lambda$validateTableSchema$26(DescriptorProperties.java:1011) at org.apache.flink.table.descriptors.DescriptorProperties.validateFixedIndexedProperties(DescriptorProperties.java:998) at org.apache.flink.table.descriptors.DescriptorProperties.validateTableSchema(DescriptorProperties.java:1017)
> {code}
> For the reason we did not ignore case in TypeStringUtils.convertType method.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)