xiaodao created FLINK-24976: ------------------------------- Summary: sink utils not check the schema info between query and sink table Key: FLINK-24976 URL: https://issues.apache.org/jira/browse/FLINK-24976 Project: Flink Issue Type: New Feature Components: Table SQL / Planner Affects Versions: 1.12.5 Reporter: xiaodao
sql like this {code:java} //CREATE TABLE source ( id INT, name STRING, PROCTIME AS PROCTIME() ) WITH ( 'connector' = 'kafka' ,'topic' = 'da' ,'properties.bootstrap.servers' = 'localhost:9092' ,'properties.group.id' = 'test' ,'scan.startup.mode' = 'earliest-offset' ,'format' = 'json' ,'json.timestamp-format.standard' = 'SQL' ); create table MyResultTable ( id int, name string, primary key (id) not enforced ) with ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://localhost:3306/test', 'table-name' = 'users', 'username' = 'root', 'password' = 'abc123' ); insert into MyResultTable select id as idx, name, age from source; {code} in this sql, sink table has field "id","name", but my query result is just "idx", "name"; the sql execute is ok; but my question why it not valid name of query and sink table; in will cause mistake when the field is too much. -- This message was sent by Atlassian Jira (v8.20.1#820001)