src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java [343:353]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        Object dataIndex = dataIndexMapping.get(i);
                        if (dataIndex != null) {
                            res[(int) dataIndex] = data[i];
                        }
                    }
                    return res;
                }
            case EXCEPTION:
                throw new RuntimeException();
            default:
                return null;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java [381:391]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        Object dataIndex = dataIndexMapping.get(i);
                        if (dataIndex != null) {
                            res[(int) dataIndex] = data[i];
                        }
                    }
                    return res;
                }
            case EXCEPTION:
                throw new RuntimeException();
            default:
                return null;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -