1.BatchDuration与ProcessTime
2.动态Batch Size
Batch越小越快,越快越安全
Spark.streaming.receiver.maxRate 设置最大速率
Spark.streaming.backpressure.rateEstimator要设置成true,最大限定数率
1.BatchDuration与ProcessTime
2.动态Batch Size
Batch越小越快,越快越安全
Spark.streaming.receiver.maxRate 设置最大速率
Spark.streaming.backpressure.rateEstimator要设置成true,最大限定数率