nwangtw commented on issue #3217: Add ack and fail to Streamlet API (#2909) URL: https://github.com/apache/incubator-heron/pull/3217#issuecomment-473364539 Most operators don't have "failure" case (for example filter, flatmap). Only ack I remember. The only way to trigger fail() I can think of now is to write a simple bolt that has failure cases and then use the applyOperator() function. I was thinking of catching exceptions as failures but it might have some unwanted side effects so it is not decided yet.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
