Hi 社区, 之前遇到一个问题,在 Flink 里面,对于一个数据流(能够撤回的)进行聚合时,当这个数据流有大量撤回时,最终聚合值会变小。这种情况之前有看到说加一个 mini batch 来减轻这种情况的影响,还有别的方法能够解决这个问题吗?
Best, LakeShen
Hi 社区, 之前遇到一个问题,在 Flink 里面,对于一个数据流(能够撤回的)进行聚合时,当这个数据流有大量撤回时,最终聚合值会变小。这种情况之前有看到说加一个 mini batch 来减轻这种情况的影响,还有别的方法能够解决这个问题吗?
Best, LakeShen