@Override
                    public Object read(ProxySdk.MessageObj body) {
                        String createTime = DateFormatUtils.format(body.getMsgTime(), "yyyyMMddHH");
                        return StringData.fromString(createTime);
                    }
Use reflection to make csv format ignore tailing unmappable.
inlong-sort/sort-formats/format-row/format-inlongmsg-pb/src/main/java/org/apache/inlong/sort/formats/inlongmsgpb/InLongMsgPbDecodingFormat.java