@Override
    public void flatMap(
            byte[] bytes,
            Collector<Row> collector) throws Exception {
        Row row;

        try {
            row = deserializationSchema.deserialize(bytes);
        } catch (Exception e) {
            if (ignoreErrors) {
                LOG.warn("Could not properly deserialize the data {}.",
                        StringUtils.byteToHexString(bytes), e);
                return;
            } else {
                throw e;
            }
        }

        if (row != null) {
            collector.collect(row);
        }
    }
True if ignore errors in the deserialization.
inlong-sort/sort-formats/format-row/format-base/src/main/java/org/apache/inlong/sort/formats/base/DefaultTableFormatDeserializer.java