[FLINK-23727] Skip null values in SimpleStringSchema#deserialize

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.13.2
• Component/s: Connectors / Common
• Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: Paul Lin
• Created: 11/Aug/21 13:24
• Updated: 14/Jul/22 10:40

Description

In Kafka use cases, it's valid to send a message with a key and a null payload as a tombstone. But SimpleStringSchema, which is frequently used as a message value deserializer, throws NPE when the input value is null. We should tolerate null values in SimpleStringSchema (simply return null to skip the records), otherwise users need to implement a custom one.

Issue Links

• links to: GitHub Pull Request #16886