Yes, I'm setting this in the topology for now:
val conf = new Config
conf.setNumWorkers(1)
....
Yes, in the UI I see Num Workers = 1, Num Executors = 5, Num Tasks = 5
Just not clear on why I see it running on all three machines. I guess I
(incorrectly) assumed that num workers was synonymous with number of
machines to run on. Was just hoping to understand why.
Thanks for your help.
On Sat, Mar 29, 2014 at 3:28 PM, Andrew Neilson <[email protected]>wrote:
> might need a little more info. By "max workers" are referring to
> topology.workers? How/when are you setting this value? From the UI do you
> see topology.workers=1 when you drill down into your topology?
>
>
> On Sat, Mar 29, 2014 at 11:04 AM, Phil Burress
> <[email protected]>wrote:
>
>> Here's a basic question to which I'm sure there is a simple answer to,
>> but for the life of me cannot figure out why.
>>
>> I have a storm cluster (1 nimbus machine, 3 worker machines), when I
>> submit a topology (set to max workers = 1, parallelism_hint =1 for all
>> spouts/bolts), why do I see it running on all 3 worker nodes? Shouldn't it
>> just run on one of those machines?
>>
>>
>>
>
