紧张枫叶

文章
8
资源
0
加入时间
2年10月21天

Flink背压的理解总结

Flink 运行时的构建块是操作符和流。每个操作符都在使用中间流,通过对它们进行转换, 产生新的流。描述网络机制的最佳类比是 Flink 使用具有有限容量的有效分布式阻塞队列。与 Java 连接线程的常规阻塞队列一样,一旦队列的缓冲区耗尽(有界容量),处理速度较慢的接收器就会降低发送器发送数据的速度。可以看一下这个外国博主的描述被压机制图片, 记录“A”进入Flink,被Task 1处理。 记录被序列化到缓冲区中, 这个缓冲区被传送到任务 2,然后从缓冲区读回记录。.