[jira] [Created] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true and threre is NPE question when use `new String(message) ` if message = null

[hehuiyuan (Jira)]

hehuiyuan created FLINK-23237:
---------------------------------

             Summary: Add log to print data that failed to deserialize when  
ignore-parse-error=true and threre is NPE question when use `new 
String(message) ` if message = null  
                 Key: FLINK-23237
                 URL: https://issues.apache.org/jira/browse/FLINK-23237
             Project: Flink
          Issue Type: Improvement
            Reporter: hehuiyuan


(1)Add log to print error data that failed to deserialize when set 
`ignore-parse-error` = `true`

(2)Threre is NPE question when use `new String(message) `  if message is null.
{code:java}
public RowData deserialize(@Nullable byte[] message) throws IOException {
    if (message == null) {
        return null;
    }
    try {
        final JsonNode root = objectReader.readValue(message);
        return (RowData) runtimeConverter.convert(root);
    } catch (Throwable t) {
        if (ignoreParseErrors) {
            return null;
        }
        throw new IOException(
                String.format("Failed to deserialize CSV row '%s'.", new 
String(message)), t);
    }
}
{code}



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