src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java [324:334]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                    + totalColumnSize
                                    + ", data column number: "
                                    + dataColumnSize
                                    + ", data field number: "
                                    + data.length
                                    + ", data: ["
                                    + StringUtils.join(data, ",")
                                    + "]");
                    lastLogHandleFieldTime = now;
                }
                return null;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java [364:374]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                    + totalColumnSize
                                    + ", data column number: "
                                    + dataColumnSize
                                    + ", data field number: "
                                    + data.length
                                    + ", data: ["
                                    + StringUtils.join(data, ",")
                                    + "]");
                    lastLogHandleFieldTime = now;
                }
                return null;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -