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
---