GitHub user lin-zhao opened a pull request:
https://github.com/apache/spark/pull/11176
[SPARK-13069][STREAMING]. Adds synchronous store() to ActorReciever.
Introduces ```storeSync()``` in ```ActorReceiver``` as a way to allow actor
receiver blocked by back pressure or maxRate.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lin-zhao/spark SPARK-13069
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/11176.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 #11176
----
commit 970e3c850a50dd8c227700449066524976eeeb0c
Author: Lin Zhao <[email protected]>
Date: 2016-02-11T00:30:38Z
SPARK-13069. Adds synchronous store() to ActorReciever.
Such that flow control works for actor 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]
