Step 1 of 4: Choose Issues

Cancel

T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due Development
Sub-task SPARK-9968

SPARK-7398 BlockGenerator lock structure can cause lock starvation of the block updating thread

Tathagata Das Tathagata Das Major Resolved Fixed  
Sub-task SPARK-9967

SPARK-7398 Rename the SparkConf property to spark.streaming.backpressure.{enable --> enabled}

Tathagata Das Tathagata Das Minor Resolved Fixed  
Sub-task SPARK-9966

SPARK-7398 Handle a couple of corner cases in the PID rate estimator

Tathagata Das Tathagata Das Blocker Resolved Fixed  
Sub-task SPARK-9556

SPARK-7398 Make all BlockGenerators subscribe to rate limit updates

Tathagata Das Tathagata Das Major Resolved Fixed  
Sub-task SPARK-8979

SPARK-7398 Implement a PIDRateEstimator

Dragos Dascalita Haut Dragos Dascalita Haut Major Resolved Fixed  
Sub-task SPARK-8978

SPARK-7398 Implement the DirectKafkaRateController

Dragos Dascalita Haut Dragos Dascalita Haut Major Resolved Fixed  
Sub-task SPARK-8977

SPARK-7398 Define the RateEstimator interface, and implement the ReceiverRateController

Dragos Dascalita Haut Dragos Dascalita Haut Major Resolved Fixed  
Sub-task SPARK-8975

SPARK-7398 Implement a mechanism to send a new rate from the driver to the block generator

Dragos Dascalita Haut Dragos Dascalita Haut Major Resolved Fixed  
Sub-task SPARK-8835

SPARK-7398 Provide pluggable Congestion Strategies to deal with Streaming load

Unassigned François Garillot Major Resolved Incomplete  

Cancel