You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/06/02 19:40:00 UTC
[jira] [Created] (FLINK-18075) Kafka connector does not call open
method of (de)serialization schema
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)