[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

[tragicjun]

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.


---