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
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
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>
>
>
&