特牛生活网

【Flink】【第五章 流处理API】Source 和 Sink_flink job source sink-CSDN博客

网友收藏
文章浏览阅读832次。Source输入Controlling Latency(控制延迟)Source传输控制策略_29集默认情况下,流中的元素不会一个一个的在网络中传输,而是缓存起来,这样可以减少连接的次数,提高效率;缓存的大小可以在Flink的配置文件、ExecutionEnvironment、或者某个算子上进行配置;输入控制延迟默认为100ms输入延迟的好处:提高吞吐量输入延迟的缺点:增加了延迟如何把握平衡?如果是为了最大吞吐量,则可以设置setBufferTimeout(-1),移除timeout_flink job source sink