27 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/io/CsvOutputFormat.java (108:176, 36%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvOutputFormat.java (110:178, 36%) 25 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/io/CsvOutputFormat.java (181:224, 33%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvOutputFormat.java (183:226, 33%) 17 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (179:208, 12%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (165:196, 12%) 10 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (211:228, 7%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (198:214, 7%) 10 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (155:171, 7%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (142:158, 7%) 10 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (103:119, 7%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (103:119, 7%) 10 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (71:87, 7%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (72:88, 7%) 9 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (123:137, 6%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (123:137, 6%) 8 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/io/CsvOutputFormat.java (54:70, 10%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvOutputFormat.java (56:72, 10%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (127:135, 4%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (78:87, 4%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (127:135, 4%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (109:118, 4%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (230:243, 4%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (217:230, 4%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (259:266, 4%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (251:258, 4%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (109:118, 4%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (78:87, 4%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (109:118, 4%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (127:135, 4%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (77:86, 4%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (109:118, 4%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (77:86, 4%) - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (127:135, 4%)