No, each operator would have its own local list. In a distributed environment it is very tricky to keep global state across all instances of operations (Flink does not support anything in this direction). If you really need it then the only way is to set the parallelism of the operator to 1. This way you ensure that all tuples pass through only one operator instance.
On Tue, 29 Sep 2015 at 13:08 defstat <defs...@gmail.com> wrote: > Will that keep a global list for all execution environment? > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/FLink-Streaming-Parallelize-ArrayList-tp2957p2959.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
