以前做过,自定义sink,更新值小于 存储值的时候不更新 在 2021-01-25 16:00:28,"LakeShen" <shenleifight...@gmail.com> 写道: >Hi 社区, > >之前遇到一个问题,在 Flink 里面,对于一个数据流(能够撤回的)进行聚合时,当这个数据流有大量撤回时,最终聚合值会变小。这种情况之前有看到说加一个 >mini batch 来减轻这种情况的影响,还有别的方法能够解决这个问题吗? > >Best, >LakeShen
- 对于 Flink 可撤回流做聚合,当上游数据撤回时,最终聚合值变小了,怎么解决这种问题。 LakeShen
- Re:对于 Flink 可撤回流做聚合,当上游数据撤回时,最终聚合值变小了,怎么解决这种问题。 Michael Ran
- Re: 对于 Flink 可撤回流做聚合,当上游数据撤回时,最终聚合值变小了,怎么解决这种问题。 Jessica.J.Wang