[jira] [Created] (FLINK-24676) Schema does not match if explain insert statement with partial column

["godfrey he (Jira)" <ji...@apache.org>]

godfrey he created FLINK-24676:
----------------------------------

             Summary: Schema does not match if explain insert statement with partial column
                 Key: FLINK-24676
                 URL: https://issues.apache.org/jira/browse/FLINK-24676
             Project: Flink
          Issue Type: Bug
            Reporter: godfrey he


create table MyTable (a int, b int) with ('connector' = 'datagen');
create table MySink (c int, d int) with ('connector' = 'print');
explain plan for insert into MySink(d) select a from MyTable where a > 10;

If execute the above statement, we will get the following exception

org.apache.flink.table.api.ValidationException: Column types of query result and sink for registered table 'default_catalog.default_database.MySink' do not match.
Cause: Different number of columns.

Query schema: [a: BIGINT]
Sink schema:  [d: BIGINT, e: INT]




--
This message was sent by Atlassian Jira
(v8.3.4#803005)