Seth Wiesman created FLINK-18075: ------------------------------------ Summary: Kafka connector does not call open method of (de)serialization schema Key: FLINK-18075 URL: https://issues.apache.org/jira/browse/FLINK-18075 Project: Flink Issue Type: Improvement Components: Connectors / Kafka, Formats (JSON, Avro, Parquet, ORC, SequenceFile) Affects Versions: 1.11.0, 1.12.0 Reporter: Seth Wiesman
The Kafka consumer and producer do not call the open methods of plain (De)SerializationSchema interfaces. Only the Keyed and Kafka specific interfaces. The updated SQL implementations such as AvroRowDataSeriailzationSchema use these methods and so SQL queries using avro and kafka will fail in a null pointer exception. cc [~aljoscha] -- This message was sent by Atlassian Jira (v8.3.4#803005)