Github user tragicjun commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r193084082 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSourceTestBase.java --- @@ -128,6 +130,82 @@ public void testDifferentFieldsAvroClass() { source.getDataStream(StreamExecutionEnvironment.getExecutionEnvironment()).getType()); } + @Test + public void testHasMapFieldsAvroClass() { --- End diff -- The issue is exposed when using KafkaAvroTableSource, but moving the unit tests to AvroRowDeSerializationSchemaTest should be fine.
---