在使用kafka、flink和mesos的流处理管道中,可以采取哪些步骤来减少延迟?
rlcwz9us1#
我们发现有一件特别的事情有很大的影响,是flink特有的,那就是设置网络缓冲区超时。通过使用0而不是默认值(100),一个简单的作业(带有滑动窗口的单个输入/输出)可以从15毫秒的平均延迟变为1毫秒。
1条答案
按热度按时间rlcwz9us1#
我们发现有一件特别的事情有很大的影响,是flink特有的,那就是设置网络缓冲区超时。
通过使用0而不是默认值(100),一个简单的作业(带有滑动窗口的单个输入/输出)可以从15毫秒的平均延迟变为1毫秒。