Spark Streaming Backpressure

1、为什么引入Backpressure                 默认情况下,Spark Streaming通过Receiver以生产者生产数据的速率接收数据,计算过程中会出现batch processing time > batch interval的情况,其中batch processing time 为实际计算一个批次花费时间, batch interval为Streaming应用设置
相关文章
相关标签/搜索