jie*_*cxy 2 backpressure apache-flink
对于操作员,输入流比其输出流快,因此其输入缓冲区将阻塞前一个操作员的输出线程,该线程将数据传输到该操作员。对?
Flink和Spark是否都通过阻塞线程来处理背压?那么它们之间有什么区别?
对于数据源,它会持续生成数据,如果其输出线程被阻塞怎么办?缓冲区会溢出吗?
| 归档时间: |
|
| 查看次数: |
1231 次 |
| 最近记录: |