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

        try {
            bytes = serializationSchema.serialize(row);
        } catch (Exception e) {
            if (ignoreErrors) {
                LOG.warn("Could not properly serialize the row {}.", row, e);
                return;
            } else {
                throw e;
            }
        }

        if (bytes != null) {
            collector.collect(bytes);
        } else {
            LOG.warn("Data is Empty.");
        }
    }
True if ignore errors in the deserialization.
inlong-sort/sort-formats/format-row/format-base/src/main/java/org/apache/inlong/sort/formats/base/DefaultTableFormatSerializer.java