Kostas and Fabian, Thanks for the advice. I guess I will find a workaround to do the state redistribution.
I also read about side outputs in this thread, which might be also an option that I will consider. http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Share-state-across-operators-td17031.html Best, Makis -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
