@Override
    public void flatMap(Row row, Collector<Row> collector) throws Exception {

        List<Row> convertedRows;

        try {
            Map<String, String> attributes = InLongMsgUtils.getAttributesFromMixedRow(row);
            byte[] data = InLongMsgUtils.getDataFromMixedRow(row);
            String streamId = InLongMsgUtils.getStreamIdFromMixedRow(row);
            Timestamp time = InLongMsgUtils.getTimeFromMixedRow(row);
            List<String> predefinedFields = InLongMsgUtils.getPredefinedFieldsFromMixedRow(row);
            List<String> fields = InLongMsgUtils.getFieldsFromMixedRow(row);
            Map<String, String> entries = InLongMsgUtils.getEntriesFromMixedRow(row);

            convertedRows =
                    convertRows(attributes, data, streamId, time, predefinedFields, fields, entries);
        } catch (Throwable t) {
            String errorMessage =
                    String.format("Could not properly convert the mixed row. Row=[%s].", row);
            if (ignoreErrors) {
                LOG.warn(errorMessage, t);
                return;
            } else {
                throw new RuntimeException(errorMessage, t);
            }
        }

        if (convertedRows != null) {
            for (Row convertedRow : convertedRows) {
                collector.collect(convertedRow);
            }
        }
    }
True if ignore errors in the deserialization.
inlong-sort/sort-formats/format-row/format-inlongmsg-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/row/AbstractInLongMsgMixedFormatConverter.java