[ https://issues.apache.org/jira/browse/SPARK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14631418#comment-14631418 ]
Apache Spark commented on SPARK-8975: ------------------------------------- User 'dragos' has created a pull request for this issue: https://github.com/apache/spark/pull/7471 > 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