Metrics consumer configuration in client's storm.yaml

2016-10-17 Thread David Koch
Hello, When submitting a Storm topology from a client instance, is the metrics consumer configuration in the client's storm.yaml respected or is this portion of the configuration exclusive to the cluster instances storm.yaml? I have the following in the client storm.yaml and the settings do not s

Question about "queue explosion"

2017-03-02 Thread David Koch
Hi, The Storm documentation mentions setting topology.max.spout.pending as a way of preventing "queue explosion"[1]. What is meant by this? Tuples piling up and eventually causing out of memory exceptions? If I understand correctly, the topology's queue and buffer sizes are all limited [2] - so at

Re: Question about "queue explosion"

2017-03-03 Thread David Koch
version 0.9.6): > >- https://github.com/apache/storm/blob/v0.9.6/storm-core/ >src/jvm/backtype/storm/messaging/netty/Server.java#L97 > > <https://github.com/apache/storm/blob/v0.9.6/storm-core/src/jvm/backtype/storm/messaging/netty/Server.java#L97> > > &