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)
