Spongebob created FLINK-24104:
---------------------------------
Summary: incorrect validation of sink schema
Key: FLINK-24104
URL: https://issues.apache.org/jira/browse/FLINK-24104
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Affects Versions: 1.12.4
Environment: Flink: 1.12.4
Reporter: Spongebob
incorrect validation of sink schema, for example, I create jdbc table `user` as
{code:java}
//代码占位符
create table user(
id int,
name varchar(32),
desc varchar(16)
){code}
And then I connect to this jdbc table in flink, when I execute my sink sql
which like
{code:java}
//代码占位符
insert into flink_catalog_user(desc, name, id) select ... // please mind that
the order of sink columns is not consist with ddl statement.{code}
, Flink application throws validation exception that is about sink schema
incorrect. So it seams
flink would ignore my sink column's order and it would get the sink table
schema instead.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
