Storm:是否可以限制失败时的重播次数(锚定)? [英] Storm: Is it possible to limit the number of replays on fail (Anchoring)?

问题描述

使用锚定时是否有限制重播次数的选项?我有一个应该解析 json 对象的元组，以防它出现异常，我希望它再重播两次.

Is there an option to limit the number of replays when using anchoring? I have a tuple that should parse json object, in case it gets an exception I prefer it will replay two more times.

我试图跟踪 Storm 用打印重播的次数，但每次我输入不可解析的值时，计数器都会显示不同的结果.

I tried to track the number of times storm is replaying with prints, but each time I entered non parse-able value the counter showed different result.

catch{
collector.fail(tuple)
} 

推荐答案

BaseRichSpout 类中的 fail 方法为空.这意味着您应该覆盖相同的方法来处理失败的元组回复策略.

The fail method in the BaseRichSpout class is empty . meaning you are supposed to override the same method to handle the failed tuple reply strategy.

这篇关于Storm:是否可以限制失败时的重播次数(锚定)?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！