You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "godfrey he (Jira)" <ji...@apache.org> on 2021/10/28 15:16:00 UTC
[jira] [Closed] (FLINK-24676) Schema does not match if explain
insert statement with partial column
[ https://issues.apache.org/jira/browse/FLINK-24676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
godfrey he closed FLINK-24676.
------------------------------
Resolution: Fixed
Fixed in 1.15.0: 37f8b380e2a962a46d287371bf37b7a97f4573cf
Fixed in 1.14.1: 4ceaac13a0b5a8eceac78f3f22c247dea62a55f3
Fixed in 1.13.4: 05d19616b200da052f345761325726d32c6c1c11
> 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
> Components: Table SQL / Planner
> Affects Versions: 1.13.0, 1.14.0, 1.15.0
> Reporter: godfrey he
> Assignee: godfrey he
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0, 1.14.1, 1.13.4
>
>
> 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)