GitHub user dragos opened a pull request:
https://github.com/apache/spark/pull/7471
[SPARK-8975][Streaming] Adds a mechanism to send a new rate from the driver
to the block generator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/typesafehub/spark
topic/streaming-bp/dynamic-rate
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/7471.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #7471
----
commit 4721c7d9394b7917b2be8fb7df5e4eb1c31d68df
Author: François Garillot <[email protected]>
Date: 2015-07-13T11:26:57Z
[SPARK-8975][Streaming] Add a mechanism to send a new rate from the driver
to the block generator
commit d15de422b973a020d5aa9035016c1274262631fb
Author: François Garillot <[email protected]>
Date: 2015-07-15T11:14:31Z
[SPARK-8975][Streaming] Adds Ratelimiter unit tests w.r.t.
spark.streaming.receiver.maxRate
commit 6369b305b87f812e0bbb6a37e2a1d338c1e1cb26
Author: Iulian Dragos <[email protected]>
Date: 2015-07-17T09:20:38Z
Merge pull request #15 from huitseeker/SPARK-8975
[SPARK-8975][Streaming] Adds a mechanism to send a new rate from the driver
to the block generator
commit 1e7b210e5f6e3600e36c9854e1887f4a03e5325a
Author: Iulian Dragos <[email protected]>
Date: 2015-07-17T14:38:10Z
Add a test for the propagation of a new rate limit from driver to receivers.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
