Hi,
In my storm application I intentionally configured the number of
ackers to be zero. But the code still calls the ack method when
processing tuples. Can this cause performance issues?
Hi Telles
Thanks for your help. I will try and get back.
Thanks
Sai
On Tue, Jul 22, 2014 at 5:51 PM, Telles Nobrega
wrote:
> A better way to find out how many instances of each component are created
> is to take a look at the Storm UI at nimbus:8080.
>
> It shows how many instances of each comp
Hi,
I am using storm for my project. I have the following use case.
I have 2 files, One file has 20 million user information.
and the other file has user id and the scores associated to that user.
I need to perform the following actions using STORM.
For each each user record I need to get the
Is there any follow up to this thread?
http://mail-archives.apache.org/mod_mbox/storm-user/201312.mbox/%3C29605543.1418.1386695558006.JavaMail.Laurent@Laurent-PC%3E
For some reason when I make names for each bolt, some of the names seem to
persist to the down stream bolts and this gets confusing.
Hi
I'm working on a topology with Storm 0.9.1-incubating and version 0.4.0 of
the net.wurstmeister.storm TransactionalTridentKafkaSpout and I'm
periodically getting an error which repeatedly takes down the worker
running the spout and persists when I kill and resubmit the topology.
Specifically, I
A better way to find out how many instances of each component are created
is to take a look at the Storm UI at nimbus:8080.
It shows how many instances of each component are running and gives you
info about it. I'm not sure if the declareOutputFields should be called as
many time as groups you hav
Hi
Could some one pls help with FieldGrouping issue i am having pls.
I am using the WordCount example from Getting Started book of Storm.
Here is the input i am providing just 1 line:
Apache Storm is great.
I have tried using 1 Spout, 1 SplitSentenceBolt and 2 WordCountBolts, and 1
Report Bolt.
Thanks Harsha. I created https://issues.apache.org/jira/browse/STORM-416
On 21 July 2014 17:05, Harsha wrote:
> the code is in core.clj in mk-include-sys-fn which calls
> system-id?(common.clj). I think UI code is fine but nimbus won't accept a
> topology which has stream-id with "__" at the b
Hi
I m trying to understand parellism in Storm a few questions about it:
1. Lets say i have only a single file i am trying to test
with a single line L1
Now if i use 2 spouts, will there be 2 spouts created
or is it only 1 spout which will b created as there is only a line.
2. Is parallelism hint
