duplicated block id: 1
size: 8 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java (186:195)
 - src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java (269:278)

duplicated block id: 2
size: 6 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGeneratorPerQueue.java (61:68)
 - src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java (56:63)