Hi, I think you are looking for BroadcastState [1].
Best, Fabian [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/broadcast_state.html Am Fr., 17. Jan. 2020 um 14:50 Uhr schrieb Soheil Pourbafrani < soheil.i...@gmail.com>: > Hi, > > According to the processing logic, I need to have a HashMap variable that > should be shared between the taskmanagers. The scenario is the HashMap data > will be continuously updated according to the incoming stream of data. > > What I observed is declaring the HashMap variable as a class attribute, it > will be shared among a single taskmanagers slots, but in case I have > multiple taskmanager, each will have a separate HashMap instance. > > What is the standard way to achieve this? Does Flink provide any utility > for that? >
