storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "P. Taylor Goetz" <ptgo...@gmail.com>
Subject Re: thread safe output collector
Date Thu, 28 Apr 2016 14:12:41 GMT
The documentation is wrong. See:

https://issues.apache.org/jira/browse/STORM-841 <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.

-Taylor

> On Apr 28, 2016, at 9:06 AM, Stephen Powis <spowis@salesforce.com> wrote:
> 
> "Its perfectly fine to launch new threads in bolts that do processing asynchronously.
OutputCollector <http://storm.apache.org/releases/current/javadocs/org/apache/storm/task/OutputCollector.html>
is thread-safe and can be called at any time."
> 
> 
> 
> From the docs for 0.9.6: http://storm.apache.org/releases/0.9.6/Concepts.html#bolts <http://storm.apache.org/releases/0.9.6/Concepts.html#bolts>
> 
> On Thu, Apr 28, 2016 at 9:03 AM, P. Taylor Goetz <ptgoetz@gmail.com <mailto:ptgoetz@gmail.com>>
wrote:
> 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 <lists.digitalpebble@gmail.com <mailto:lists.digitalpebble@gmail.com>>
wrote:
> 
>> 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-Zj3wbYr8evsAQJC6u_g@mail.gmail.com%3E
<https://mail-archives.apache.org/mod_mbox/storm-user/201602.mbox/%3CCA+-fM0urPf3FUERoZywPzmxu-KDbGF-Zj3wbYr8evsAQJC6u_g@mail.gmail.com%3E>
>> 
>> Anyone who could confirm this?
>> 
>> Thanks
>> 
>> On 27 April 2016 at 14:05, Steven Lewis <Steven.Lewis@walmart.com <mailto:Steven.Lewis@walmart.com>>
wrote:
>> I have conflicting information, and have not checked personally but has the output
collector finally been made thread safe for emitting in version 1.0 or 0.10? I know it was
a huge problem in 0.9.5 when trying to do threading in a bolt for async future calls and emitting
once it returns.
>> 
>> This email and any files transmitted with it are confidential and intended solely
for the individual or entity to whom they are addressed. If you have received this email in
error destroy it immediately. *** Walmart Confidential ***
>> 
>> 
>> 
>> --
>> 
>> Open Source Solutions for Text Engineering
>> 
>> http://www.digitalpebble.com <http://www.digitalpebble.com/>
>> http://digitalpebble.blogspot.com/ <http://digitalpebble.blogspot.com/>
>> #digitalpebble <http://twitter.com/digitalpebble>
> 


Mime
View raw message