Hi, Basically, it's the standard word-count topology, 1 spout, 1 split, 1 count, and 1 sink.
Now, suppose I give the parallelism hint to each of them as 1:2:1:1. Hence, there are two executors for split are created. My questions is how can I maintain a global shared counter for both of the two threads of split. Is it possible to do that in storm? I have tried some methods e.g., AtomicInteger, but later I realized that the use of serlization makes the contents of every thread instance of split isolated. Is there any way to work-around of it? Many thanks.
