duplicated block id: 1 size: 36 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (177:220) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (258:303) duplicated block id: 2 size: 33 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (331:376) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (522:567) duplicated block id: 3 size: 20 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (295:326) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (466:497) duplicated block id: 4 size: 16 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (370:388) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (428:446) duplicated block id: 5 size: 15 cleaned lines of code in 2 files: - style/rmq_codeStyle.xml (51:65) - style/rmq_codeStyle.xml (104:118) duplicated block id: 6 size: 10 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java (96:105) - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java (187:196) duplicated block id: 7 size: 10 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java (77:86) - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java (116:125) duplicated block id: 8 size: 10 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (324:334) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (364:374) duplicated block id: 9 size: 10 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (157:168) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (225:236) duplicated block id: 10 size: 9 cleaned lines of code in 2 files: - style/rmq_codeStyle.xml (105:113) - style/rmq_codeStyle.xml (132:140) duplicated block id: 11 size: 9 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (153:162) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (166:175) duplicated block id: 12 size: 9 cleaned lines of code in 2 files: - style/rmq_codeStyle.xml (52:60) - style/rmq_codeStyle.xml (132:140) duplicated block id: 13 size: 9 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (370:378) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (399:407) duplicated block id: 14 size: 9 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java (183:191) - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java (126:134) duplicated block id: 15 size: 9 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java (168:176) - src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java (170:178) duplicated block id: 16 size: 9 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java (133:141) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java (150:158) duplicated block id: 17 size: 9 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (399:407) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (428:436) duplicated block id: 18 size: 8 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (361:368) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (419:426) duplicated block id: 19 size: 8 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java (266:275) - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java (281:290) duplicated block id: 20 size: 8 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (343:353) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (381:391) duplicated block id: 21 size: 8 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (78:85) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (91:98) duplicated block id: 22 size: 8 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (390:397) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (419:426) duplicated block id: 23 size: 8 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (361:368) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (390:397) duplicated block id: 24 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java (71:76) - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java (108:113) duplicated block id: 25 size: 6 cleaned lines of code in 2 files: - style/rmq_codeStyle.xml (90:95) - style/rmq_codeStyle.xml (141:146) duplicated block id: 26 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (71:76) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (80:85) duplicated block id: 27 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java (169:175) - src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java (218:224) duplicated block id: 28 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (383:388) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (575:580) duplicated block id: 29 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (259:267) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (281:289) duplicated block id: 30 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java (214:219) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java (229:234) duplicated block id: 31 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (54:59) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (57:62) duplicated block id: 32 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (286:292) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (453:459) duplicated block id: 33 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java (57:64) - src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java (52:59) duplicated block id: 34 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (259:267) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (303:311) duplicated block id: 35 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (409:417) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (438:446) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (380:388) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (409:417) duplicated block id: 37 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (390:399) - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (586:595) duplicated block id: 38 size: 6 cleaned lines of code in 2 files: - style/rmq_codeStyle.xml (91:96) - style/rmq_codeStyle.xml (119:124) duplicated block id: 39 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (281:289) - src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java (303:311) duplicated block id: 40 size: 6 cleaned lines of code in 2 files: - src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java (191:196) - src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java (234:239)