Jingsong Lee created FLINK-15401:
------------------------------------
Summary: Planner should set sink field names to setKeyFields of
upsert sink
Key: FLINK-15401
URL: https://issues.apache.org/jira/browse/FLINK-15401
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Jingsong Lee
Fix For: 1.10.0
There is a upsert sink my_sink with schema (a int, cnt int).
SQL:
{code:java}
INSERT INTO my_sink SELECT a, count(*) from my_source group by a;{code}
will work.
But:
{code:java}
INSERT INTO my_sink SELECT b, count(*) from my_source group by b;
{code}
will fail. Because the name "b" not match "a".
Now, we just pass field names from plan to setKeyFields. We need pass field
names from sink.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
