Github user tragicjun commented on the issue:
https://github.com/apache/flink/pull/6082
Thans @suez1224 @twalthr for reviewing. I've moved the unit tests from
KafkaAvroTableSourceTestBase to AvroRowDeSerializationSchemaTest. As for other
comments, plz see my comments.---
