You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Nadav Ashkenazi (Jira)" <ji...@apache.org> on 2020/11/30 15:23:00 UTC
[jira] [Created] (STORM-3717) Fail function won’t be called if msgId was not entered in emmit
Nadav Ashkenazi created STORM-3717:
--------------------------------------
Summary: Fail function won’t be called if msgId was not entered in emmit
Key: STORM-3717
URL: https://issues.apache.org/jira/browse/STORM-3717
Project: Apache Storm
Issue Type: Task
Reporter: Nadav Ashkenazi
Hey,
When I tried to use your technology, I tried to implement fail method on Spout (implementing BaseRichBolt), on the spout I emitted without msgId and the fail function was not even called even though I implemented it.
I was stuck on this for around 7 hours trying to figure why my code doesn’t reach fail.
I think the current flow is not intuitive, I think default msgId (-1 or something) for msg without msgId or even a warning or exception is better than the current flow.
I would like to hear your opinion about that if you still support this flow about why
you prefer to implement like that.
thank you!:)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)