Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
1.11.0, 1.12.0
Description
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
Attachments
Issue Links
- duplicates
-
FLINK-17940 It will throw NullPointerException when write data with Avro format using new property key in SQL-Client
- Closed
- links to