flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 陈帅 <casel.c...@gmail.com>
Subject Flink RetractStream如何转成AppendStream?
Date Sun, 08 Dec 2019 02:07:59 GMT
在用Flink做实时数仓时遇到group by统计后需要将结果发到kafka,但是现在的kafka
sink是不支持RetractStream,因此会报错,有没有什么方法将RetractStream转成AppendStream(例如,忽略撤回的消息,只发送更新的消息),从而可以将结果发到kafka?
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message