Merge pull request #730 from xiaokang/limit-shell-pending add config to limit ShellBolt internal _pendingWrites queue length Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/54ccd71a Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/54ccd71a Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/54ccd71a Branch: refs/heads/master Commit: 54ccd71a54e4c4f96c65dc0c03a573b878f82fc3 Parents: 9a60d7a 5b071c0 Author: Nathan Marz Authored: Sun Nov 10 12:16:22 2013 -0800 Committer: Nathan Marz Committed: Sun Nov 10 12:16:22 2013 -0800 ---------------------------------------------------------------------- storm-core/src/jvm/backtype/storm/Config.java | 6 ++++++ storm-core/src/jvm/backtype/storm/task/ShellBolt.java | 5 +++++ 2 files changed, 11 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/54ccd71a/storm-core/src/jvm/backtype/storm/Config.java ----------------------------------------------------------------------