[
https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-25171:
----------------------------------
Assignee: shouzuo meng
> When the DDL statement was executed, the column names of the Derived Columns
> were not validated
> -----------------------------------------------------------------------------------------------
>
> Key: FLINK-25171
> URL: https://issues.apache.org/jira/browse/FLINK-25171
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.14.0
> Reporter: shouzuo meng
> Assignee: shouzuo meng
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0, 1.14.4
>
> Attachments: 5261638775663_.pic.jpg
>
>
> When I execute the DDL statement, I mistakenly use the duplicate field name
> in THE SQL, but the execution result of the program does not throw any
> exception or prompt. In MergeTableLikeUtilTest. Java# mergePhysicalColumns
> add repeated the TableColumn (), also do not throw any exceptions, review the
> code logic found only on the source table schema fields, It is not a
> duplicate and derived tables and fields of the source table is verified, and
> no field of derived tables if repeated verification, adding
> physicalFieldNamesToTypes, there will be a repeating field coverage,The
> following are the execution statements and the results
> DDL sql：
> CREATE TABLE test1 (
> `log_version` string COMMENT '日志版本',
> `log_version` INTEGER COMMENT '日志版本',
> `pv_time` string COMMENT '日志时间'
> ) with(
> 'connector' = 'kafka',
> 'topic' = 'xxx',
> 'properties.bootstrap.servers' = 'xxx:9110',
> 'scan.startup.mode'='latest-offset',
> 'format' = 'json',
> )
> {code:java}
> StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
> TableResult result = tEnv.executeSql(
> CREATE TABLE test1 (
> `log_version` string COMMENT '日志版本',
> `log_version` INTEGER COMMENT '日志版本',
> `pv_time` string COMMENT '日志时间'
> ) with(
> 'connector' = 'kafka',
> 'topic' = 'xxx',
> 'properties.bootstrap.servers' = 'xxx:9110',
> 'scan.startup.mode'='latest-offset',
> 'format' = 'json',
> )
> )
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
