[
https://issues.apache.org/jira/browse/FLINK-14046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-14046:
--------------------------
Fix Version/s: (was: 1.10.0)
1.11.0
Change the fix version to 1.11.0 to facilitate issue tracking for 1.10.0 (after
feature freeze), please feel free to close it later if reached consensus
[~jark]. Thanks.
> 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
> Fix For: 1.11.0
>
> 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)
