[
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)
