28 9 月 Flink, 大数据 Posted by 蓝染君 flink-22 迟到数据的处理 推迟水印推进 在水印产生时,设置一个乱序容忍度(延迟时间),推迟系统的时间的推进,保证窗口计算被延迟执行,为乱序的数据争取更多的时间进... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-15 物理分区算子 常见的物理分区策略有:随机分配(Random)、轮询分配(Round-Robin)、重缩放(Rescale)和广播(Broadcast) Continue reading