Hello Gyula & Stefan, Below I attach a similar situation that I am trying to resolve, [1]
I am also using *managed operator state*, but I have some trouble with the flink documentation. I believe it is not that clear. So, I have the following questions: 1 -- Can I concatenate all the partial states of all the parallel instances of a .process() operator for example? Ans : I believe YES. I should use unionListState(), but I do not know how. 2 -- Can I a perform the merge of all the state in one parallel instance and then forward the state through a Side Stream inside the the .processElement() function?? 3 -- If (1) and (2) have affirmative answers, could you elaborate further of how this is done? Best, Max [1] http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Maintain-heavy-hitters-in-Flink-application-td16965.html -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
