Re: What happpens when a Task fails in storm?

2015-01-27 Thread Sajith
l than on the task level, and it is more likely to > be effective. > > On Wed, Jan 28, 2015 at 12:21 AM, Sajith wrote: > >> Hi Nathan, >> >> Thanks for your reply. Could you please ellaborate more on the answer >> please? Is that the failed task will be reinsta

Re: What happpens when a Task fails in storm?

2015-01-27 Thread Sajith
the worker > process. > > On Tue, Jan 27, 2015 at 2:11 AM, Sajith wrote: > >> Hi all, >> >> Can someone please clarify what action does supervisor takes when a >> certain tasks fails within a worker process? >> >> Also, if some other task is emitting

What happpens when a Task fails in storm?

2015-01-26 Thread Sajith
Hi all, Can someone please clarify what action does supervisor takes when a certain tasks fails within a worker process? Also, if some other task is emitting tuples to the failed task how does the emitting task handle the failure of receiving task? Is there a way to capture and handler such case

java.io.InvalidClassException when a component is changed an topology is re-submitted.

2015-01-20 Thread Sajith
Hi all, I had a running topology and then I changed a component of it by adding additional member variable to one of the components to store the task iD(private int taskId). After making this change and submitting the Jar i get the following error. When I remove this variable every things starts

Re: Sliding window on numerical data?

2014-11-10 Thread Sajith
Hi Johannes, You can also use Sidddhi complex event processing engine to achieve your tasks. [1] is a bolt I wrote using Siddhi. [1] https://github.com/sajithshn/siddhi-storm/blob/master/src/main/java/org/wso2/siddhi/storm/component/SiddhiBolt.java On Tue, Nov 11, 2014 at 1:29 AM, Manoj Jaiswal