Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5958
If it turns out that we need to do a bit more design work on the
deserialization schema, we could incrementally fix the issue that triggered
this PR by actually extending the KeyedDeserializationSchema with a new default
method.---
