[FLINK-25171] When the DDL statement was executed, the column names of the Derived Columns were not validated

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.14.0
• Fix Version/s: 1.14.4, 1.15.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available

Language

Java

• Assignee: shouzuo meng
• Reporter: shouzuo meng
• Created: 06/Dec/21 03:53
• Updated: 25/Jan/22 17:10
• Resolved: 25/Jan/22 04:35

Description

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',
)

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',
)
) 

Issue Links

• links to: GitHub Pull Request #18017