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: 
 <CAMHaYAe5xsg3rM_+Mut676NQN0XQXyFSAnJdo521-u6_bi+x=Q@mail.gmail.com>
References: 
 <CAOy42CtGEbYXgqKU0m1t7QkGN=eLBkSJXBg8EgpuZ_i1fLpVAw@mail.gmail.com>
	<CAOy42CsNjUNypJ2s9c7wj-uWWCosafTYA4zHrxPy5woXOfLK8g@mail.gmail.com>
	<CAMHaYAe5xsg3rM_+Mut676NQN0XQXyFSAnJdo521-u6_bi+x=Q@mail.gmail.com>
Date: Tue, 16 Feb 2016 12:23:17 +0200
Message-ID: 
 <CAOy42CsMqQDGojgFzzYdqmpCrT7+tFj7rhtX-gQr8Xbhf_c14A@mail.gmail.com>
Subject: Re: localOrShuffleGrouping load balanced tuple distribution
From: Spico Florin <spicoflorin@gmail.com>
To: user@storm.apache.org
Content-Type: multipart/alternative; boundary=001a11c2593497691d052be085e9

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

Hi, Nathan!
  Thank you for your answer. You are right: the only bolts that are used
will be the ones located nearby the spout. The other two will be unused. If
we increase the  number of workers to 5, then it will behave as
shuffleGrouping (distributing evenly among the bolts).
I got it!
 Regards,
 Florin

On Mon, Feb 15, 2016 at 3:56 PM, Nathan Leung <ncleung@gmail.com> wrote:

> It will use the local bolts.
>
> On Mon, Feb 15, 2016 at 8:32 AM, Spico Florin <spicoflorin@gmail.com>
> wrote:
>
>>
>> Hello!
>>    Suppose that I have the following scenario
>> 1. One spout
>> 2. One bolt with hintParallelism set to 4
>> 3. Bolt connected with the spout with localOrShuffleGrouping
>> 4. 2 slots available
>> 5. We use the the default schedulder (round-robin)
>>
>> Give the above scenario, the distribution over the workers will be:
>> worker 1: spout, bolt, bolt
>> worker 2: bolt, bolt
>>
>> Here are my questions:
>> 1. Will the spout uses the 4 bolts?
>> 2. Will the data distributed evenly between these bolts?
>> 3. Due to localorShuffleGrouping method, only the local bolts will be
>> used (the ones from the worker 1) or all the workers?
>>
>> I look forward for your answers.
>> Thank you.
>>  Florin
>>
>>
>>
>>
>>
>

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

<div dir=3D"ltr">Hi, Nathan!<div>=C2=A0 Thank you for your answer. You are =
right: the only bolts that are used will be the ones located nearby the spo=
ut. The other two will be unused. If we increase the =C2=A0number of worker=
s to 5, then it will behave as shuffleGrouping (distributing evenly among t=
he bolts).=C2=A0</div><div>I got it!</div><div>=C2=A0Regards,</div><div>=C2=
=A0Florin</div></div><div class=3D"gmail_extra"><br><div class=3D"gmail_quo=
te">On Mon, Feb 15, 2016 at 3:56 PM, Nathan Leung <span dir=3D"ltr">&lt;<a =
href=3D"mailto:ncleung@gmail.com" target=3D"_blank">ncleung@gmail.com</a>&g=
t;</span> wrote:<br><blockquote class=3D"gmail_quote" style=3D"margin:0 0 0=
 .8ex;border-left:1px #ccc solid;padding-left:1ex"><div dir=3D"ltr">It will=
 use the local bolts.</div><div class=3D"HOEnZb"><div class=3D"h5"><div cla=
ss=3D"gmail_extra"><br><div class=3D"gmail_quote">On Mon, Feb 15, 2016 at 8=
:32 AM, Spico Florin <span dir=3D"ltr">&lt;<a href=3D"mailto:spicoflorin@gm=
ail.com" target=3D"_blank">spicoflorin@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"><div><div><div dir=3D"ltr"><div class=3D"gmai=
l_quote"><br><div dir=3D"ltr">Hello!<div>=C2=A0 =C2=A0Suppose that I have t=
he following scenario</div><div>1. One spout</div><div>2. One bolt with hin=
tParallelism set to 4</div><div>3. Bolt connected with the spout with local=
OrShuffleGrouping</div><div>4. 2 slots available</div><div>5. We use the th=
e default schedulder (round-robin)</div><div><br></div><div>Give the above =
scenario, the distribution over the workers will be:</div><div>worker 1: sp=
out, bolt, bolt</div><div>worker 2: bolt, bolt</div><div><br></div><div>Her=
e are my questions:</div><div>1. Will the spout uses the 4 bolts?</div><div=
>2. Will the data distributed evenly between these bolts?</div><div>3. Due =
to localorShuffleGrouping method, only the local bolts will be used (the on=
es from the worker 1) or all the workers?</div><div><br></div><div>I look f=
orward for your answers.</div><div>Thank you.</div><span><font color=3D"#88=
8888"><div>=C2=A0Florin</div><div><br></div><div><br></div><div><br></div><=
/font></span></div>
</div><br></div>
</div></div></blockquote></div><br></div>
</div></div></blockquote></div><br></div>

--001a11c2593497691d052be085e9--