1- Is there any particular reason other than consistency in the state
regarding at least once processing of messages for forcing to emit anchored
tuples.

2- What are the downsides of emitting tuple without anchoring?

*Error:*
Caused by: java.lang.UnsupportedOperationException: Bolts in a stateful
topology must emit anchored tuples. at
org.apache.storm.topology.BaseStatefulBoltExecutor$AnchoringOutputCollector.emit(BaseStatefulBoltExecutor.java:162)
~[storm-core-1.1.0.jar:1.1.0]

-- 
Thanks & Regards,
Anshu Shukla

Reply via email to