Re: 使用Kafka Sink时报错：AppendStreamTableSink doesn't support consuming update changes

Dear Leonard Xu: 我会去关注这个issue，非常感谢答疑。 原始邮件 发件人: Leonard Xu 收件人: user-zh 发送时间: 2020年8月12日(周三) 16:05 主题: Re: 使用Kafka Sink时报错：AppendStreamTableSink doesn't support consuming update changes Hi Group by 和 left join 都是会有 retract 消息的，这类消息需要UpsertStreamTableSink才能处理， Kafka connetor 目前的实现是

Re: 使用Kafka Sink时报错：AppendStreamTableSink doesn't support consuming update changes

Hi Group by 和 left join 都是会有 retract 消息的，这类消息需要UpsertStreamTableSink才能处理， Kafka connetor 目前的实现是AppendStreamTableSink，所以不能处理 社区已经有一个issue在处理这个问题了，应该1.12能提供这个功能。 Best Leonard [1]https://issues.apache.org/jira/browse/FLINK-18826 > 在

回复：使用Kafka Sink时报错：AppendStreamTableSink doesn't support consuming update changes

是不是update-mode 改用 update模式 --原始邮件-- 发件人: "user-zh"

使用Kafka Sink时报错：AppendStreamTableSink doesn't support consuming update changes

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 我希望能够在sql校验时也能使upsert操作作用于kafka sink，或者等upsert完成，再写入kafka 附上执行sql： create table kafka_table_1 (