Hi all, I have two streams in which I need to keep counts of different metrics that will have to be shared by both of the streams. So they will be sharing some state once they have finished processing the stream. My question is if I should do this as a sink aggregating what I need at the end or by doing them as stateful operators. I tried putting two hashmaps at the sinks of my streams, but one stream fills the hashmap and the other one can not update it. I guess they are not shared or I am doing something wrong. Any pointers or suggestions would be great! Thanks!
Renato M.
