12 duplicated lines in:
  - flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/typeinfo/IterationRecordTypeInfo.java (41:60, 27%)
  - flink-ml-lib/src/main/java/org/apache/flink/ml/common/typeinfo/PriorityQueueTypeInfo.java (51:70, 24%)

6 duplicated lines in:
  - flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/event/GloballyAlignedEvent.java (50:57, 25%)
  - flink-ml-lib/src/main/java/org/apache/flink/ml/common/typeinfo/PriorityQueueSerializer.java (113:120, 5%)

6 duplicated lines in:
  - flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/typeinfo/IterationRecordTypeInfo.java (80:87, 13%)
  - flink-ml-lib/src/main/java/org/apache/flink/ml/common/typeinfo/PriorityQueueSerializer.java (113:120, 5%)

6 duplicated lines in:
  - flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/event/SubtaskAlignedEvent.java (57:63, 16%)
  - flink-ml-lib/src/main/java/org/apache/flink/ml/common/typeinfo/PriorityQueueSerializer.java (113:120, 5%)

6 duplicated lines in:
  - flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationRecord.java (132:138, 7%)
  - flink-ml-lib/src/main/java/org/apache/flink/ml/common/typeinfo/PriorityQueueSerializer.java (113:120, 5%)

6 duplicated lines in:
  - flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/typeinfo/IterationRecordSerializer.java (206:213, 3%)
  - flink-ml-lib/src/main/java/org/apache/flink/ml/common/typeinfo/PriorityQueueSerializer.java (113:120, 5%)