src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java [157:168]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                rowData.setField(
                        index,
                        StringSerializer.deserialize(
                                fieldValue,
                                fieldTypes[index],
                                fieldDataTypes[index],
                                new HashSet<>()));
            } catch (Exception e) {
                skip = handleException(rowData, index, data, e);
            }
        }
        if (skip) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java [225:236]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    rowData.setField(
                            index,
                            StringSerializer.deserialize(
                                    fieldValue,
                                    fieldTypes[index],
                                    fieldDataTypes[index],
                                    new HashSet<>()));
                } catch (Exception e) {
                    skip = handleException(rowData, index, data, e);
                }
            }
            if (skip) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -