1 Flink的背压(Backpressure)是指当下游算子处理数据的速度不及上游算子传递数据的速度时,会导致数据始终堆积在网络层或内存中,会导致系统效率下降,出现背压现象。
背压的危害:
解决方法:
2 Flink通过一套精确的一次性(Exactly-Once)的计算状态管理维持端到端数据的一致性,其关键技术如下:
微信扫一扫
1 Flink的背压(Backpressure)是指当下游算子处理数据的速度不及上游算子传递数据的速度时,会导致数据始终堆积在网络层或内存中,会导致系统效率下降,出现背压现象。
背压的危害:
解决方法:
2 Flink通过一套精确的一次性(Exactly-Once)的计算状态管理维持端到端数据的一致性,其关键技术如下:
相关推荐