Mailing-List: contact user-help@storm.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@storm.apache.org
MIME-Version: 1.0
In-Reply-To: 
 <CAFwSPC2oDwFHvcc8L8pvU=chpm=bC3q4DzzeQmpvHu_xOnAsFg@mail.gmail.com>
References: 
 <CAPgE=sk-Oxq1OjBncuZRZkF+NR98n5TpXhKBkmOmRk7DRApiOw@mail.gmail.com>
	<CAFwSPC2oDwFHvcc8L8pvU=chpm=bC3q4DzzeQmpvHu_xOnAsFg@mail.gmail.com>
Date: Wed, 17 Feb 2016 15:00:03 +0000
Message-ID: 
 <CA+-fM0urPf3FUERoZywPzmxu-KDbGF-Zj3wbYr8evsAQJC6u_g@mail.gmail.com>
Subject: Re: Is SpoutOutputCollector thread-safe?
From: Julien Nioche <lists.digitalpebble@gmail.com>
To: user@storm.apache.org
Content-Type: multipart/alternative; boundary=001a113cfef83dd895052bf88185

--001a113cfef83dd895052bf88185
Content-Type: text/plain; charset=UTF-8

Is that true of all OutputCollectors or just SpoutOutputCollector? Is
http://storm.apache.org/documentation/Troubleshooting.html#nullpointerexception-from-deep-inside-storm
<http://storm.apache.org/documentation/Troubleshooting.html> still an issue
with 0.10.0 and above?

Couldn't find any reference to this in
http://storm.apache.org/2015/11/05/storm0100-released.html

Thanks

Julien


On 16 February 2016 at 17:59, Abhishek Agarwal <abhishcool@gmail.com> wrote:

> It is not thread safe in 0.9.4.  It is thread safe in later versions
> (0.10.0 onwards)
>
> Excuse typos
> On Feb 16, 2016 11:01 PM, "Evgeniy Khyst" <evgeniy.khist@gmail.com> wrote:
>
>> Hello!
>>
>> I'm currently using Apache Storm 0.9.4 and have question about
>> thread-safety of *SpoutOutputCollector*. Is it safe to call *emit *method
>> from different threads?
>> In documentation (http://storm.apache.org/documentation/Concepts.html)
>> it is said that *OutputCollector *is not thread-safe, and all emits,
>> acks, and fails must happen on the same thread.
>> But in Javadoc (
>> https://storm.apache.org/apidocs/backtype/storm/spout/ISpout.html) it is
>> said that *SpoutOutputCollector* is thread-safe and should be saved as
>> an instance variable of this spout object.
>> Please, provide a little bit more details about thread-safety of
>> *SpoutOutputCollector* and validity of calling *emit *method from
>> different threads.
>>
>> Thanks.
>>
>> Best regards,
>> Evgeniy
>>
>


-- 

*Open Source Solutions for Text Engineering*

http://www.digitalpebble.com
http://digitalpebble.blogspot.com/
#digitalpebble <http://twitter.com/digitalpebble>

--001a113cfef83dd895052bf88185
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">Is that true of all OutputCollectors or just SpoutOutputCo=
llector? Is=C2=A0<a href=3D"http://storm.apache.org/documentation/Troublesh=
ooting.html">http://storm.apache.org/documentation/Troubleshooting.html#nul=
lpointerexception-from-deep-inside-storm</a>=C2=A0still an issue with 0.10.=
0 and above?<div><br></div><div>Couldn&#39;t find any reference to this in=
=C2=A0<a href=3D"http://storm.apache.org/2015/11/05/storm0100-released.html=
">http://storm.apache.org/2015/11/05/storm0100-released.html</a></div><div>=
<br></div><div><div>Thanks</div><div><br></div><div>Julien<br><div><br></di=
v></div></div></div><div class=3D"gmail_extra"><br><div class=3D"gmail_quot=
e">On 16 February 2016 at 17:59, Abhishek Agarwal <span dir=3D"ltr">&lt;<a =
href=3D"mailto:abhishcool@gmail.com" target=3D"_blank">abhishcool@gmail.com=
</a>&gt;</span> wrote:<br><blockquote class=3D"gmail_quote" style=3D"margin=
:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex"><p dir=3D"ltr">It =
is not thread safe in 0.9.4.=C2=A0 It is thread safe in later versions (0.1=
0.0 onwards)</p>
<p dir=3D"ltr">Excuse typos</p><div class=3D"HOEnZb"><div class=3D"h5">
<div class=3D"gmail_quote">On Feb 16, 2016 11:01 PM, &quot;Evgeniy Khyst&qu=
ot; &lt;<a href=3D"mailto:evgeniy.khist@gmail.com" target=3D"_blank">evgeni=
y.khist@gmail.com</a>&gt; wrote:<br type=3D"attribution"><blockquote class=
=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;padd=
ing-left:1ex"><div dir=3D"ltr">Hello!<br><br>I&#39;m currently using Apache=
 Storm 0.9.4 and have question about thread-safety of=C2=A0<i>SpoutOutputCo=
llector</i>. Is it safe to call=C2=A0<i>emit=C2=A0</i>method from different=
 threads?<br>In documentation (<a href=3D"http://storm.apache.org/documenta=
tion/Concepts.html" target=3D"_blank">http://storm.apache.org/documentation=
/Concepts.html</a>) it is said that=C2=A0<i>OutputCollector=C2=A0</i>is not=
 thread-safe, and all emits, acks, and fails must happen on the same thread=
.<br>But in Javadoc (<a href=3D"https://storm.apache.org/apidocs/backtype/s=
torm/spout/ISpout.html" target=3D"_blank">https://storm.apache.org/apidocs/=
backtype/storm/spout/ISpout.html</a>) it is said that=C2=A0<i>SpoutOutputCo=
llector</i>=C2=A0is thread-safe and should be saved as an instance variable=
 of this spout object.<br><div>Please, provide a little bit more details ab=
out thread-safety of=C2=A0<i>SpoutOutputCollector</i>=C2=A0and validity of =
calling=C2=A0<i>emit=C2=A0</i>method from different threads.</div><div><br>=
</div><div>Thanks.</div><div><br></div><div>Best regards,</div><div>Evgeniy=
</div></div>
</blockquote></div>
</div></div></blockquote></div><br><br clear=3D"all"><div><br></div>-- <br>=
<div class=3D"gmail_signature"><div dir=3D"ltr"><div><span style=3D"border-=
collapse:separate;color:rgb(0,0,0);font-family:&#39;Times New Roman&#39;;fo=
nt-variant:normal;font-weight:normal;letter-spacing:normal;line-height:norm=
al;text-indent:0px;text-transform:none;white-space:normal;word-spacing:0px;=
font-size:medium"><span style=3D"font-family:arial;font-size:small"><b styl=
e=3D"font-style:normal;color:rgb(0,0,0);font-family:arial,helvetica,sans-se=
rif"><br style=3D"color:rgb(51,51,51);font-family:arial,helvetica,sans-seri=
f"></b><span style=3D"color:rgb(102,102,102);font-family:arial,helvetica,sa=
ns-serif"><i><span style=3D"color:rgb(51,51,51)">Open Source Solutions for =
Text Engineering</span></i></span></span></span></div><div><span style=3D"b=
order-collapse:separate;font-family:&#39;Times New Roman&#39;;font-variant:=
normal;font-weight:normal;letter-spacing:normal;line-height:normal;text-ind=
ent:0px;text-transform:none;white-space:normal;word-spacing:0px;font-size:m=
edium"><span style=3D"font-family:arial;font-size:small"><span style=3D"fon=
t-family:arial,helvetica,sans-serif"><i><font color=3D"#333333"><br></font>=
</i></span></span><a href=3D"http://www.digitalpebble.com/" style=3D"color:=
rgb(0,0,0);font-family:arial,sans-serif;font-size:12.8px" target=3D"_blank"=
>http://www.digitalpebble.com</a><span style=3D"color:rgb(0,0,0);font-famil=
y:arial;font-size:small"><span style=3D"color:rgb(102,102,102);font-family:=
arial,helvetica,sans-serif"><br></span></span></span><span style=3D"color:r=
gb(102,102,102)"><a href=3D"http://digitalpebble.blogspot.com/" target=3D"_=
blank">http://digitalpebble.blogspot.com/</a></span><span style=3D"color:rg=
b(102,102,102)"><br><a href=3D"http://twitter.com/digitalpebble" target=3D"=
_blank">#digitalpebble</a></span><br></div></div></div>
</div>

--001a113cfef83dd895052bf88185--