[FLINK-11820] SimpleStringSchema handle message record which value is null

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Won't Fix
• Affects Version/s: 1.7.2, 1.8.0
• Component/s: Connectors / Kafka
• Labels: pull-request-available
• Assignee: lamber-ken
• Reporter: lamber-ken
• Due: 08/Mar/19
• Created: 05/Mar/19 07:19
• Updated: 03/Sep/19 09:12
• Resolved: 03/Sep/19 09:12

Description

when kafka msg queue contains some records which value is null, flink-kafka-connector can't process these records.

for example, msg queue like bellow.

msg

null

msg

msg

msg

msg

 for normal, use SimpleStringSchema to process msg queue data

env.addSource(new FlinkKafkaConsumer010("topic", new SimpleStringSchema(), properties));

 but, will get NullPointerException

java.lang.NullPointerException
	at java.lang.String.<init>(String.java:515)
	at org.apache.flink.api.common.serialization.SimpleStringSchema.deserialize(SimpleStringSchema.java:75)
	at org.apache.flink.api.common.serialization.SimpleStringSchema.deserialize(SimpleStringSchema.java:36)

 

Issue Links

• is duplicated by: FLINK-12400 NullpointerException using SimpleStringSchema with Kafka
• links to: GitHub Pull Request #7987
• links to: GitHub Pull Request #7987
• links to: GitHub Pull Request #8583