Github user pnowojski commented on the issue:

    https://github.com/apache/flink/pull/6403
  
    One issue. Please copy 
    > According to the DefinedFieldMapping interface the field mapping can also 
contain the input fields. However, the Kafka table source factory was calling 
SchemaValidator#deriveFieldMapping with its own schema instead of the the input 
type.
    
    to the commit message


---

Reply via email to