Re: thread safe output collector

tTuple functions. Now with that said, bolt >> executes should not be long running computations either, but can be longer >> than the spouts nextTuple function. >> >> >> >> *From:* Stephen Powis [mailto:spo...@salesforce.com] >> *Sent:* Thursday, April 28

Re: thread safe output collector

aid, bolt > executes should not be long running computations either, but can be longer > than the spouts nextTuple function. > > > > *From:* Stephen Powis [mailto:spo...@salesforce.com] > *Sent:* Thursday, April 28, 2016 11:59 AM > *To:* user@storm.apache.org > *Subject:* Re:

RE: thread safe output collector

To: user@storm.apache.org Subject: Re: thread safe output collector So the Spout documentation (assuming its correct...) here (http://storm.apache.org/releases/current/Concepts.html#spouts) mentions this: "The main method on spouts is nextTuple. nextTuple either emits a new tuple int

Re: thread safe output collector

ache.org>> > Date: Thursday, April 28, 2016 at 10:58 AM > To: "user@storm.apache.org <mailto:user@storm.apache.org>" > mailto:user@storm.apache.org>> > Subject: Re: thread safe output collector > > So the Spout documentation (assuming its correct..

Re: thread safe output collector

user@storm.apache.org>" mailto:user@storm.apache.org>> Subject: Re: thread safe output collector So the Spout documentation (assuming its correct...) here (http://storm.apache.org/releases/current/Concepts.html#spouts) mentions this: "The main method on spouts is nextTuple. nextTupl

Re: thread safe output collector

So the Spout documentation (assuming its correct...) here ( http://storm.apache.org/releases/current/Concepts.html#spouts) mentions this: "The main method on spouts is nextTuple. nextTuple either emits a new tuple into the topology or simply returns if there are no new tuples to emit. *It is imper

Re: thread safe output collector

Thanks for the clarification On 28 April 2016 at 15:12, P. Taylor Goetz wrote: > The documentation is wrong. See: > > https://issues.apache.org/jira/browse/STORM-841 > > At some point it looks like the change made there got reverted. I will > reopen it to make sure the documentation is corrected

Re: thread safe output collector

The documentation is wrong. See: https://issues.apache.org/jira/browse/STORM-841 At some point it looks like the change made there got reverted. I will reopen it to make sure the documentation is corrected. OutputCollector is NOT thread-safe.

Re: thread safe output collector

"Its perfectly fine to launch new threads in bolts that do processing asynchronously. OutputCollector is thread-safe and can be called at any time." >From the docs for 0.9.6: http://storm.apache.org/rel

Re: thread safe output collector

IIRC there was discussion about making it thread safe, but I don't believe it was implemented. -Taylor > On Apr 28, 2016, at 3:52 AM, Julien Nioche > wrote: > > Hi Stephen > > I asked the same question in February but did not get a reply > > https://mail-archives.apache.org/mod_mbox/storm-u

Re: thread safe output collector

Hi Stephen I asked the same question in February but did not get a reply https://mail-archives.apache.org/mod_mbox/storm-user/201602.mbox/%3cca+-fm0urpf3fuerozywpzmxu-kdbgf-zj3wbyr8evsaqjc6...@mail.gmail.com%3E Anyone who could confirm this? Thanks On 27 April 2016 at 14:05, Steven Lewis wrot