13 duplicated lines in:
  - flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementTypeInfo.java (40:60, 30%)
  - flink-ml-lib/src/main/java/org/apache/flink/ml/common/typeinfo/PriorityQueueTypeInfo.java (50:70, 26%)

7 duplicated lines in:
  - flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java (489:497, 1%)
  - flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java (245:253, 3%)

6 duplicated lines in:
  - flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementSerializer.java (156:163, 5%)
  - flink-ml-lib/src/main/java/org/apache/flink/ml/common/typeinfo/PriorityQueueTypeInfo.java (90:97, 12%)

6 duplicated lines in:
  - flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/KeyAndValueSerializer.java (167:173, 5%)
  - flink-ml-lib/src/main/java/org/apache/flink/ml/common/typeinfo/PriorityQueueSerializer.java (113:120, 5%)