[jira] [Created] (FLINK-15401) Planner should set sink field names to setKeyFields of upsert sink

[Shang Yuanchun (Jira)]

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)