举个例子比如我想要
insert into mysql_sink
select 
     ID,
     amount, 
     ………
 from source
groupby ID;

这里就是想按照id为key,在数据库里更新这个id对应的amount等其他值。

但这样子不能通过calcite的sqlvalidation,select后面不能有非聚合项,必须在groupby后面加上所有select后面的项。
但这样带来一个问题,这样子key的state无限增长(比如说amount是一个随机的double数),job跑不久就会fail掉。

请问大家有什么办法能只指定部分字段为key来规避掉这个问题,谢谢。
之前发过一封类似的邮件,没有回复,只好再发一封,见谅。




发自我的iPhone

回复