support consuming update changes"/>
AppendStreamTableSink doesn‘t support consuming update changes
Flink版本:1.11.0
问题:
flink-sql,数据经过group by 和left join后写入kafka sink,会在语法校验阶段报错:
AppendStreamTableSink doesn't support consuming update changes which is produced by node GroupAggregate
解答:
这个是正常现象。 如果你用了普通的group by的话,那么它的结果就是有更新的,所以需要sink支持写入update的结果,
但是kafka目前只能写入append的数据,所以会报上面的错误。
你可以尝试下用window group[1],在这个文档的第二个示例里,它的结果是append的,不会有更新。
[1].html#aggregations
更多推荐
AppendStreamTableSink doesn‘t support consuming update changes
发布评论