[jira] [Commented] (SPARK-8975) Implement a mechanism to send a new rate from the driver to the block generator

2015-07-17 Thread Apache Spark (JIRA) 

[ 
https://issues.apache.org/jira/browse/SPARK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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

[jira] [Commented] (SPARK-8975) Implement a mechanism to send a new rate from the driver to the block generator

2015-07-14 Thread JIRA 

[ 
https://issues.apache.org/jira/browse/SPARK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14625930#comment-14625930
 ] 

François Garillot commented on SPARK-8975:
--

Typesafe PR : https://github.com/typesafehub/spark/pull/15/files

 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