Shangwen Tang created FLINK-16735: ------------------------------------- Summary: FlinkKafkaProducer should check that it is not null before sending a record Key: FLINK-16735 URL: https://issues.apache.org/jira/browse/FLINK-16735 Project: Flink Issue Type: Bug Components: Connectors / JDBC Affects Versions: 1.10.0 Reporter: Shangwen Tang Attachments: image-2020-03-24-11-25-47-898.png
In our user scenario, some users implemented the KafkaSerializationSchema and sometimes returned a null record, resulting in a null pointer exception !image-2020-03-24-11-25-47-898.png! -- This message was sent by Atlassian Jira (v8.3.4#803005)