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

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.13.0, 1.14.0, 1.15.0
• Fix Version/s: 1.13.6, 1.14.3, 1.15.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: godfrey he
• Reporter: godfrey he
• Created: 28/Oct/21 02:19
• Updated: 15/Dec/21 01:44
• Resolved: 28/Oct/21 15:15

Description

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]

Issue Links

• links to: GitHub Pull Request #17584