AppendStreamTableSink doesn't support consuming update changes

[xiao cai]

Hi Jark：


版本：1.11.0
问题：flink-sql，数据经过group by 和left join后写入kafka sink，会在语法校验阶段报错：
AppendStreamTableSink doesn't support consuming update changes which is produced by node GroupAggregate

[Benchao Li-2]

Hi，

这个是正常现象。 如果你用了普通的group by的话，那么它的结果就是有更新的，所以需要sink支持写入update的结果，
但是kafka目前只能写入append的数据，所以会报上面的错误。
你可以尝试下用window group[1]，在这个文档的第二个示例里，它的结果是append的，不会有更新。

[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql/queries.html#aggregations

xiao cai <[hidden email]> 于2020年8月12日周三 下午3:42写道：

> Hi Jark：
>
>
> 版本：1.11.0
> 问题：flink-sql，数据经过group by 和left join后写入kafka sink，会在语法校验阶段报错：
> AppendStreamTableSink doesn't support consuming update changes which is
> produced by node GroupAggregate



--

Best,
Benchao Li