Everyone faces this issue. That's why we anchor the tuples while emitting
from the bolt, so that if it does not get delivered, the spout's fail()
method will receive the failure notification. Make sure you anchor your
tuples
<http://storm.apache.org/releases/current/Guaranteeing-message-processing.html>
and use the fail() method:
@Override
public void fail(Object msgId) {
if (msgId instanceof MyClass) {
MyClass one = (MyClass) msgId;
}
}
On Wed, Jun 15, 2016 at 3:44 PM, Chen Junfeng <[email protected]> wrote:
> I found when I emit some messages from one bolt to another bolt, some of
> them are lost.
>
>
>
> I counted the number of messages emitted in first bolt and the number of
> messages received in the beginning of excute() method in the second bolt.
> The two numbers should be equal but actually nearly half of them are lost.
>
>
>
> Does anyone meet the similar problem?
>
>
>
>
>
> 发送自 Windows 10 版邮件 <https://go.microsoft.com/fwlink/?LinkId=550986>应用
>
>
>
--
Regards,
Navin
