Storm UI resets stats on exceptions

2016-12-05 Thread Mohsen Bande
Hello all, when any of bolts throws an exception, UI resets all stats (acked, failed, ...) is there any way to prevent it from that?

How to set number of Nimbus child processes

2016-12-05 Thread Mohsen Bande
Hello all, starting storm 1.0.2 with the default config, htop shows that many java processes started running. how can i control this? i can't see any relevant config in storm

Re: how to pause a topology

2016-11-07 Thread Mohsen Bande
and let all the other spout/bolt group from > this "control bolt". Then what you need is just to send something like > "control tuple" from "control bolt" to pause or resume other components. > Hope this will help you. > > ------

any way to expire tuples after some time

2016-11-06 Thread Mohsen Bande
Hi Everyone i need tuples in streams to expire if there is no task to process them for a while is there any way to implement this in storm concepts? i'm looking for a way to expire tuples when they are waiting for a bolt to process them. when incoming input tuples rate is higher than bolt processin

how to pause a topology

2016-11-06 Thread Mohsen Bande
Hi Everyone, i know that it is possible to deactivate the spouts is there any way to pause all spout/bolts? i.e. keep waiting tuples from processing? i don't wan't to discard them, as some time later i need to resume the topology Thank you

how to clone existing topology

2016-11-06 Thread Mohsen Bande
Hi! in a project, i want to clone a topology with a new name, and having them use different sources of data (e.g. listening on different ports) i want this to be able to deactivate/kill topology at will, without affecting streams flowing in other topologies. is this possible to clone a topology in