Iulian Dragos created SPARK-8975: ------------------------------------ Summary: Implement a mechanism to send a new rate from the driver to the block generator Key: SPARK-8975 URL: https://issues.apache.org/jira/browse/SPARK-8975 Project: Spark Issue Type: Sub-task Components: Streaming Reporter: Iulian Dragos
Full design doc [here|https://docs.google.com/document/d/1ls_g5fFmfbbSTIfQQpUxH56d0f3OksF567zwA00zK9E/edit?usp=sharing] - Add a new message, {{RateUpdate(newRate: Long)}} that ReceiverSupervisor handles in its endpoint - Add a new method to ReceiverTracker {{def sendRateUpdate(streamId: Int, newRate: Long): Unit}} this method sends an asynchronous RateUpdate message to the receiver supervisor corresponding to streamId - update the rate in the corresponding block generator. -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org