回复：Handling back pressure in Flink.

2018-07-05 Thread Zhijiang(wangzhijiang999)
) 20:40 收件人：user 主　题：Handling back pressure in Flink. Hi, In spark one can handle back pressure by setting the spark conf parameter: sparkConf.set("spark.streaming.backpressure.enabled","true") With backpressure you make Spark Streaming application stable, i.e. receives dat

Handling back pressure in Flink.

2018-07-04 Thread Mich Talebzadeh
Hi, In spark one can handle back pressure by setting the spark conf parameter: sparkConf.set("spark.streaming.backpressure.enabled","true") With backpressure you make Spark Streaming application stable, i.e. receives data only as fast as it can process it. In general one needs to ensure that you