You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "hailong wang (Jira)" <ji...@apache.org> on 2019/09/10 15:13:00 UTC

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

hailong wang created FLINK-14046:
------------------------------------

             Summary: 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
             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)