Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6082#discussion_r192768664
--- 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 --
I think we don't need changes in Kafka-related classes. This is an issue
with the `AvroRowDeserializationSchema` and should be covered by the
`AvroRowDeSerializationSchemaTest`.
---
