Re: Assignment of threads to tcp ports

Is it the pluggable scheduler that is being discussed here? http://storm.apache.org/releases/1.0.1/Storm-Scheduler.html Richards Peter. On Wed, Aug 31, 2016 at 11:44 PM, Kyle Nusbaum wrote: > There's no API to do that currently. It's entirely up to the scheduler and > will like

Re: Supervisor shutting down frequently

current work directory of supervisor is set to /home/storm. This change in the script helped me to fix the issue. Thanks, Richards Peter.

Re: Supervisor shutting down frequently

, Richards Peter.

Re: Clarification regarding packaging of storm-core jar

Thank you Taylor and Grant for your replies. I will try the approaches suggested by both of you. Richards Peter.

Clarification regarding packaging of storm-core jar

encounter a situation when we have to upgrade an individual transitive dependency how should I go forward? Could you please share your thoughts about the same? Thanks, Richards Peter.

Re: [ANNOUNCE] Apache Storm 0.10.0-beta Released

Thanks all, Richards Peter.

Re: [ANNOUNCE] Apache Storm 0.10.0-beta Released

5? Thanks, Richards Peter.

Re: How Spout emits multiple Tuples!

have access to the directory location. Thanks, Richards Peter.

Re: Cleanup method not called for the BaseBasicBolt when the topology is killed

Thank you all for sharing your thoughts/comments. Richards Peter.

Re: Are Hooks the right place to process acknowledgement and failures at each bolt level?

Hi Any thoughts/comments about this topic? Thanks, Richards Peter.

Re: Cleanup method not called for the BaseBasicBolt when the topology is killed

will be really useful to have such a notification mechanism. Richards Peter.

Re: Cleanup method not called for the BaseBasicBolt when the topology is killed

database connections) from spout and bolt, it would another good reason for storm upgrade. Thanks, Richards Peter.

Are Hooks the right place to process acknowledgement and failures at each bolt level?

spout focus only on clearing the input stream. - Are Hooks the right place to process acknowledgement and failures at each bolt level? - Will there be any performance impact if we use Hooks for processing acknowledgement and failure of tuples? Thanks, Richards Peter.

Re: Updating a live topology

your queuing system will push the unacknowledged messages to the new topology also if it is launched before the tuple timeout interval(i.e. before the first topology is killed). Hope this helps. Richards Peter.

Re: Cleanup Cassandra session

/GntJmOZZn4M Thanks, Richards Peter.

Safely clearing storm_data directory

Hi all, Can somebody share their thoughts about clearing storm_data directory periodically? Is there a safe way to clear old files residing in this directory while the topologies are running? Thanks, Richards Peter.

Re: RE: how can I set the worker jvm dynamically?

property will be applicable for all workers spawned for a topology. Regards, Richards Peter.

Re: Is storm a good choice for our architecture?

You can use custom scheduler to execute specific tasks on a particular machine. Please check the following mail thread: https://groups.google.com/forum/m/#!topic/storm-user/n_-HZWSdcmM Regards, Richards Peter.

Re: programmatically call rebalance

If you have any such concerns, you can limit the use of nimbus client api for your specific cases. I prefer to use this api because it is straight forward and suits my use cases. Regards, Richards Peter

Re: programmatically call rebalance

cbc4c3d35-93b6-45fa-960d-47325ccaf...@gmail.com%3e> He has asked to configure one more property in the map. Regards, Richards Peter.

Re: programmatically call rebalance

://github.com/apache/storm/blob/master/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java Regards, Richards Peter.