Github user tragicjun commented on the issue:
https://github.com/apache/flink/pull/6026
Hi @suez1224, I've added some checks in the unit
tests(KafkaAvroTableSourceTestBase), which would fail before the fix.
Meanwhile, I found an issue in the previous version (specifically, the
produced type info should be inferred from AvroRecordClass not TableSchema),
which has been fixed. Would you please take a review? ---
