richt richt created FLINK-20535:
-----------------------------------
Summary: "GROUPING SETS" query result cannot upsert to table
Key: FLINK-20535
URL: https://issues.apache.org/jira/browse/FLINK-20535
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Affects Versions: 1.11.2
Reporter: richt richt
{code:java}
//代码占位符
insert into table_sink
city , case when dt is null then 'ALL' else dt end,
count(*) from table_source
group by GROUPING SETS ((city, dt), dt)
{code}
even i spicify the primary key in the table_sink , but it still throw
exeception
"UpsertStreamTableSink requires that Table has a full primary keys if it is
updated."
at
org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToPlanInternal(StreamExecLegacySink.scala:93)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
