[jira] [Created] (FLINK-20535) "GROUPING SETS" query result cannot upsert to table

[Shang Yuanchun (Jira)]

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)