You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/03 13:38:00 UTC

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

     [ https://issues.apache.org/jira/browse/FLINK-18075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jark Wu closed FLINK-18075.
---------------------------
    Resolution: Fixed

- master (1.12.0): bc16d526b36a37915d01005f849e7c7faf805ee1
- 1.11.0: 2bdc6ec563705f220e14ca13d1f7e2a1bb47b444

> 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
>            Assignee: Dawid Wysakowicz
>            Priority: Blocker
>              Labels: pull-request-available
>             Fix For: 1.11.0
>
>
> 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)