- 链接地址:https://blog.csdn.net/weixin_43589563/article/details/122455645
- 链接标题:【Flink】【第五章 流处理API】Source 和 Sink_flink job source sink-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:9580
文章浏览阅读832次。Source输入Controlling Latency(控制延迟)Source传输控制策略_29集默认情况下,流中的元素不会一个一个的在网络中传输,而是缓存起来,这样可以减少连接的次数,提高效率;缓存的大小可以在Flink的配置文件、ExecutionEnvironment、或者某个算子上进行配置;输入控制延迟默认为100ms输入延迟的好处:提高吞吐量输入延迟的缺点:增加了延迟如何把握平衡?如果是为了最大吞吐量,则可以设置setBufferTimeout(-1),移除timeout_flink job source sink
版权声明:本文发布于特牛生活网 内容均来源于互联网 如有侵权联系删除