Thanks. Does storm enable ack by default?
And when building topology, if we do not specify stream name, does the downstream bolt would receive all stream from upstream bolt, or just default stream? 2017-12-22 17:05 GMT+08:00 Jungtaek Lim <kabh...@gmail.com>: > One thing to note for asynchronous bolt is that "emit" does some magic > things regarding to anchors (calculating value for XOR-ing) which affects > "ack", so "ack" should be after emitting all the tuples to downstream. > AFAIK there's no other restriction at all. (beware tuple timeout even > asynchronous) > > - Jungtaek Lim (HeartSaVioR) > > 2017년 12월 22일 (금) 오후 5:36, Jinhua Luo <luajit...@gmail.com>님이 작성: >> >> Hi All, >> >> In real cases, chances are that we need to do some async tasks in the >> blot's execute(), the async tasks may be completed after execute() >> returns, so is it ok to emit tuples to downstream then? And is it ok >> to emit tuples anchoring the input tuple at that time? >> >> Similarly, is it ok to ack the input tuple in async way after execute() >> returns? >> >> I'm newbie to storm, please help, thanks!
