g"
Subject: Re: initState method not invoked in Storm 1.0
Hi Arun,
Yes, that is one way of getting it wrong. Another way is assigning your bolt to
a variable of a stateless type before doing setBolt. Since Java lacks dynamic
dispatch, the stateless overload will be chosen in that case.
Rega
now, can you provide parallelism hint while you add stateful bolt to
> the topology ?
>
> Thanks,
> Arun
>
> From: Alexander T
> Reply-To: "user@storm.apache.org"
> Date: Friday, April 15, 2016 at 2:38 PM
> To: "user@storm.apache.org"
> Subject: Re:
, April 15, 2016 at 2:52 PM
To: "user@storm.apache.org"
Subject: Re: initState method not invoked in Storm 1.0
Hi!
Thank you for your answers. Yes I will provide the hint parallelism.
Regarding, the constraint that I'm facing should I emit from both spout and
stateful bolt ancho
>
> For now, can you provide parallelism hint while you add stateful bolt to
> the topology ?
>
> Thanks,
> Arun
>
> From: Alexander T
> Reply-To: "user@storm.apache.org"
> Date: Friday, April 15, 2016 at 2:38 PM
>
> To: "user@storm.apache.org"
to the
topology ?
Thanks,
Arun
From: Alexander T
Reply-To: "user@storm.apache.org"
Date: Friday, April 15, 2016 at 2:38 PM
To: "user@storm.apache.org"
Subject: Re: initState method not invoked in Storm 1.0
Hi Arun,
I meant that it's very easy to use the wrong set
Hi, Alex!
There is no special method addBolt in the API TopologyBuilder for . I
have used the topologyBuilder.setBolt("myId", new TimeSeriesStatefulBolt())
without parallelism_hint declared and the API dismiss the statefulness.
I did NOT get any errors in the Logs.
What I have found is the
StatefulTopology in
the storm-starter and check if you see the same behavior ?
Thanks,
Arun
From: Alexander T
Reply-To: "user@storm.apache.org"
Date: Friday, April 15, 2016 at 2:06 PM
To: "user@storm.apache.org"
Subject: Re: initState method not invoked in Storm 1.0
Hi Spico,
Are
Hi Spico,
Are you adding your bolt to the topology with the special methods for
stateful bolts? It's quite easy to use the regular addBolt method and it
will in that case be treated as a stateless one.
Cheers
Alex
On Apr 15, 2016 10:33 AM, "Spico Florin" wrote:
> Hello!