Flink MiniBatch的作用

在Blink的流式任务中,State相关的操作通常都会成为整个任务的性能瓶颈。实时计算部-查询和优化团队开发了MiniBatch功能,大幅降低了State操作的开销。 假设数据流在短时间内累计有N条数据(分布在M个key上) 开启minibatch的前后对比:操作state由2N次转变为2M次 MiniBatch的一个典型场景-无限流上的GroupBy 在Blink-SQL中,通常会使用无限流的G
相关文章
相关标签/搜索