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)
