GitHub user Ethanlm opened a pull request:
https://github.com/apache/storm/pull/2338
[STORM-2744] add in restart timeout for backpressure
[JIRA-STORM-2744](https://issues.apache.org/jira/browse/STORM-2744)
Backpressure mechanism relies on zookeeper to transfer signals.
If at some point, the topology wants to turn off the throttle but zookeeper
failed to delete the backpressure node, then the throttle will be on. And in
that case, it's very likely that the znode will never be deleted and thus the
throttle will always be on. The spouts will stop indefinitely.
We want to add a restart timeout so that even the above case happened, the
spouts can continue to work.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/Ethanlm/storm STORM-2744
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/2338.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 #2338
----
commit bebc09cfb744f760bf14395513145165cd214e77
Author: Ethan Li <[email protected]>
Date: 2017-09-20T14:33:29Z
[STORM-2744] add in restart timeout for backpressure
----
---
