You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/11 23:37:00 UTC
[jira] [Updated] (FLINK-14046) DDL property 'format.fields.#.type'
should ignore case
[ https://issues.apache.org/jira/browse/FLINK-14046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-14046:
-----------------------------------
Labels: pull-request-available (was: )
> 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.10.0
>
>
> 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.2#803003)