@Override
    public void flatMap(RowData rowData, Collector<RowData> collector) throws Exception {

        List<RowData> convertedRowDatas;

        try {
            Map<String, String> attributes = InLongMsgUtils.getAttributesFromMixedRowData(rowData);
            byte[] data = InLongMsgUtils.getDataFromMixedRowData(rowData);
            String streamId = InLongMsgUtils.getTidFromMixedRowData(rowData);
            Timestamp time = InLongMsgUtils.getTimeFromMixedRowData(rowData);
            List<String> predefinedFields = InLongMsgUtils.getPredefinedFieldsFromMixedRowData(rowData);
            List<String> fields = InLongMsgUtils.getFieldsFromMixedRowData(rowData);
            Map<String, String> entries = InLongMsgUtils.getEntriesFromMixedRowData(rowData);

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

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