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/
Hi All,
I'm sorry if I'm double posting, but I posted it before subscribing and I
don't see it in my post lists. So I'm posting it again.
The Flink app we are trying to build is as such: read from kafka, sort the
messages according to some dependency rules, and only send messages that
have satis
