You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/26 08:55:00 UTC
[jira] [Created] (FLINK-15401) Planner should set sink field names
to setKeyFields of upsert sink
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)