[jira] [Created] (FLINK-18075) Kafka connector does not call open method of (de)serialization schema

[Shang Yuanchun (Jira)]

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)