flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Renato MarroquĂ­n Mogrovejo <renatoj.marroq...@gmail.com>
Subject Newbie question
Date Sun, 14 Feb 2016 21:22:49 GMT
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.

View raw message