I am using storm 0.8.2 with ack mechanism and I have nothing about failing and trying again The questions are:
- Can I limit the number of retiaries?
- How can I handle the error on my own? I want to try again on some errors (for example, the database does not answer) and I do not want to try again on other (like there is an error parsing the tuple).
Can I limit the number of retries?
Not a built-in feature you should apply logic to your spout for this.
How do I control errors? Meaning for some errors (i.e. DB is not responding) I want to try again and for others (i.e. to pars the error pipe) I do not want to try again.
I would recommend to read the complete storm document and in particular, otherwise, I will post it here. Once you understand how Storm handles processing, then Will be really easy to implement.
Comments
Post a Comment