举个例子比如我想要 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