Hello,
I am new to Storm. I am testing the TridentWordCount.java example in a
distributed storm cluster (I eliminated the DRPC part for simplicity).
>From the storm ui result, I notice that there are $spoutcoord-spout0$ and
$spout0$ in Bolts, which are not defined in the topology.
What are they? Could anyone tell me?
Besides, the number of tasks in the ui do not match the parallelismHint in
the code. Why does this happen?
Here are the trident code and screenshot of ui result for your reference:
*TridentState wordCounts = topology*
* .newStream("spout1", spout)*
* .parallelismHint(8)*
* .each(new Fields("sentence"), new Split(), new Fields("word"))*
* .groupBy(new Fields("word"))*
* .persistentAggregate(new MemoryMapState.Factory(), new Count(), new
Fields("count"))*
* .parallelismHint(10);*
[image: Inline image 1]
Thanks!
Best,
Xiang
