the awesome docs @
https://storm.apache.org/documentation/Understanding-the-parallelism-of-a-Storm-topology.html
From: Asif Ihsan [mailto:asifihsan.ih...@gmail.com]
Sent: Thursday, May 14, 2015 9:47 AM
To: user@storm.apache.org
Subject: Re: Multiple Workers in local mode gives error
If I create 6 work
If I create 6 workers for 5 bolts and 1 spout. Then how will these spout
and bolts be distributed among workers.
On Thu, May 14, 2015 at 5:34 PM, 임정택 wrote:
> Yes, right.
> Worker is a JVM instance which can contains one or more executors, each
> executor is spout, bolt, acker, etc.
>
> 2015년 5월
2015 5:23 AM
> *To:* user@storm.apache.org
> *Subject:* Re: Multiple Workers in local mode gives error
>
>
>
> You are right about it. What does multiple workers means. Does it mean
> that when I run topology with single worker than i will see one single
> process handling
Yes, right.
Worker is a JVM instance which can contains one or more executors, each
executor is spout, bolt, acker, etc.
2015년 5월 14일 목요일, Asif Ihsan님이 작성한 메시지:
> You are right about it. What does multiple workers means. Does it mean
> that when I run topology with single worker than i will see o
retest with one worker.
From: Asif Ihsan [mailto:asifihsan.ih...@gmail.com]
Sent: Thursday, May 14, 2015 5:23 AM
To: user@storm.apache.org
Subject: Re: Multiple Workers in local mode gives error
You are right about it. What does multiple workers means. Does it mean that
when I run topology with
You are right about it. What does multiple workers means. Does it mean that
when I run topology with single worker than i will see one single process
handling all the bolts and when running 6 workers for 5 bolts and 1 spout
than i will see 6 separate processes running each bolt and spout? M i
right
Hi.
Storm serializes tuples when tuple should be sent to other (remote) worker.
In other words, Storm doesn't serialize tuples when destination is local
task. That's why you didn't meet error when testing with 1 worker.
MapEventBean seems to be not serializable, so you need to convert to other
da
I am using Esper in one of the bolts of the Storm topology. Bolt emit
MapEventBean array (EventBean[]). With the single worker topology run
smoothly. With multiple workers it gives following error in emit function
call.
May 14, 2015 2:37:07 PM clojure.tools.logging$eval1$fn__7 invoke
SEVERE: Async
Asif:
Would love to help you, however, we will need way more details. Why don't
you start with telling us what the error is? How are you detecting the
error?
You will want to look over both the supervisor and worker logs.
Thank you for your time!
+
Jeff Maass
linkedin.com
