[jira] [Created] (FLINK-24406) JSONKeyValueDeserializationSchema code bug

["胡剑 (Jira)" <ji...@apache.org>]

胡剑 created FLINK-24406:
--------------------------

             Summary: JSONKeyValueDeserializationSchema code bug
                 Key: FLINK-24406
                 URL: https://issues.apache.org/jira/browse/FLINK-24406
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
            Reporter: 胡剑


if record.key() or record.value() is an empty array, an exception will be thrown here, causing the entire program to hang

 

I think it should be fixed like this

 

if (record.key() != null && record.key().length > 0) {
 node.set("key", mapper.readValue(record.key(), JsonNode.class));
 }
 if (record.value() != null && record.value().length > 0) {
 node.set("value", mapper.readValue(record.value(), JsonNode.class));
 }



--
This message was sent by Atlassian Jira
(v8.3.4#803005)