开发者社区> 问答> 正文

对于 Flink 可撤回流做聚合,当上游数据撤回时,最终聚合值变小了,怎么解决这种问题。

如题*来自志愿者整理的flink邮件归档

展开
收起
JACKJACK 2021-12-08 10:54:39 871 0
1 条回答
写回答
取消 提交回答
  • 对的是我!

    要看一下具体的Sql 或者具体的算子。 下游的 sink needRetract=false的情况,有些场景可以抑制上游算子的回撤,Retract 可以优化成 Upsert*来自志愿者整理的flink邮件归档

    2021-12-08 11:13:41
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载