【发布时间】:2019-09-06 14:35:27
【问题描述】:
我知道每次都会消耗一批数据以减少网络调用,但是消耗率仅取决于源运营商还是 Sink 的确认也很重要?这种情况下怎么处理burst?
【问题讨论】:
我知道每次都会消耗一批数据以减少网络调用,但是消耗率仅取决于源运营商还是 Sink 的确认也很重要?这种情况下怎么处理burst?
【问题讨论】:
源和接收器松散耦合。如果 sink 跟不上,那么这将导致背压通过作业图向上级联,从而阻止 source 能够以比消耗更快的速度向下游写入数据,这将减慢它的读取速度(从而匹配水槽)。
请参阅How Apache Flink handles backpressure 了解更多信息。
【讨论】: