Taier
Taier copied to clipboard
flinksql 语法检测报错
flinksql如下:
insert
into
sumsink
select
col1 as col1,
sum(col2) as col2
from
sumsrc group by col1;
语法检测,错误信息: Caused by: java.lang.IllegalStateException: please declare primary key for sink table when query contains update/delete record.