src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java [214:219]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                    .map(
                                            mq ->
                                                    new RocketMQSourceSplit(
                                                            mq,
                                                            checkMap.get(mq).f0,
                                                            checkMap.get(mq).f1,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java [229:234]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                    .map(
                                            mq ->
                                                    new RocketMQSourceSplit(
                                                            mq,
                                                            checkMap.get(mq).f0,
                                                            checkMap.get(mq).f1,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -