@Override
    public Row deserialize(byte[] message) throws IOException {
        String decoderStr = new String(message, charsetName);
        JsonNode root = objectMapper.readTree(decoderStr);
        this.parseTree(root, null);
        return convertTopRow();
    }
source data parse to json format
<p>
Date: 2019/12/12
Company: www.dtstack.com

@author maqi
core/src/main/java/com/dtstack/flink/sql/format/dtnest/DtNestRowDeserializationSchema.java