Thanks! I tested the KeyedSerializationSchema and it indeed works. I tried to use TypeInformationKeyValueSerializationSchema just to make things a bit more automated :)
-- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Serialization-Issue-tp19400p19407.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
