Solved it by using a key selector that returns a constant, so that creates a "pseudo" keyedStream with only one partition.
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Solved it by using a key selector that returns a constant, so that creates a "pseudo" keyedStream with only one partition.
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/