Github user cricket007 commented on the issue:
https://github.com/apache/flink/pull/5995
What about implementing a `KeyedDeserializationSchema` for Avro?---
Github user cricket007 commented on the issue:
https://github.com/apache/flink/pull/5995
What about implementing a `KeyedDeserializationSchema` for Avro?---