duplicated block id: 1 size: 144 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/utils/python/PythonTableUtils.scala (279:432) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/util/python/PythonTableUtils.scala (223:376) duplicated block id: 2 size: 83 cleaned lines of code in 2 files: - flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/RowDataVectorizer.java (58:143) - flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/OrcNoHiveBulkWriterFactory.java (117:202) duplicated block id: 3 size: 66 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/StringUtf8Utils.java (138:213) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StringUtf8Utils.java (135:210) duplicated block id: 4 size: 66 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/StringUtf8Utils.java (226:301) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StringUtf8Utils.java (223:298) duplicated block id: 5 size: 55 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NonReusingSortMergeCoGroupIterator.java (88:156) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/ReusingSortMergeCoGroupIterator.java (89:157) duplicated block id: 6 size: 54 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/call.scala (89:157) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/call.scala (163:231) duplicated block id: 7 size: 52 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/StringUtf8Utils.java (51:117) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StringUtf8Utils.java (48:114) duplicated block id: 8 size: 47 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeInfoCheckUtils.scala (100:149) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/typeutils/TypeCheckUtils.scala (227:276) duplicated block id: 9 size: 44 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/PythonCalcSplitRule.scala (47:98) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/PythonCalcSplitRule.scala (47:98) duplicated block id: 10 size: 43 cleaned lines of code in 2 files: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormat.java (166:211) - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java (209:254) duplicated block id: 11 size: 40 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java (110:151) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java (111:152) duplicated block id: 12 size: 34 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/subquery.scala (34:72) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/subquery.scala (53:91) duplicated block id: 13 size: 34 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/TreeNode.scala (36:76) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/TreeNode.scala (36:76) duplicated block id: 14 size: 31 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecMatch.scala (342:380) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamMatch.scala (282:320) duplicated block id: 15 size: 31 cleaned lines of code in 2 files: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopInputFormatBase.java (207:254) - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopInputFormatBase.java (229:276) duplicated block id: 16 size: 29 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (355:390) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (327:362) duplicated block id: 17 size: 28 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2101:2136) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2388:2423) duplicated block id: 18 size: 27 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/PlannerExpressionConverter.scala (338:367) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/PlannerExpressionConverter.scala (785:814) duplicated block id: 19 size: 27 cleaned lines of code in 2 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CoGroupRawDescriptor.java (49:85) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CoGroupDescriptor.java (53:89) duplicated block id: 20 size: 26 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PythonCorrelateSplitRule.java (160:190) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/rules/logical/PythonCorrelateSplitRule.java (167:197) duplicated block id: 21 size: 26 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/SplitPythonConditionFromJoinRule.scala (49:81) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/SplitPythonConditionFromJoinRule.scala (49:81) duplicated block id: 22 size: 24 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (231:260) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (210:239) duplicated block id: 23 size: 23 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PythonCorrelateSplitRule.java (104:130) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/rules/logical/PythonCorrelateSplitRule.java (111:137) duplicated block id: 24 size: 23 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/collection.scala (77:105) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/collection.scala (203:231) duplicated block id: 25 size: 22 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PythonCorrelateSplitRule.java (132:158) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/rules/logical/PythonCorrelateSplitRule.java (139:165) duplicated block id: 26 size: 22 cleaned lines of code in 2 files: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java (208:232) - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcLookupFunction.java (218:242) duplicated block id: 27 size: 21 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalWindowAggregateRuleBase.scala (232:255) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/common/LogicalWindowAggregateRule.scala (245:268) duplicated block id: 28 size: 21 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7Configuration.java (47:70) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6Configuration.java (56:79) duplicated block id: 29 size: 21 cleaned lines of code in 3 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java (55:78) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka011TableSource.java (58:81) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka010TableSource.java (58:81) duplicated block id: 30 size: 21 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1700:1722) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1932:1954) duplicated block id: 31 size: 20 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (195:219) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (174:198) duplicated block id: 32 size: 20 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/PreValidateReWriter.scala (208:229) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/calcite/PreValidateReWriter.scala (145:166) duplicated block id: 33 size: 20 cleaned lines of code in 3 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7ApiCallBridge.java (96:119) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6ApiCallBridge.java (95:118) - flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/Elasticsearch5ApiCallBridge.java (99:122) duplicated block id: 34 size: 19 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (1164:1185) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (998:1019) duplicated block id: 35 size: 19 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalMatch.scala (95:116) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalMatch.scala (94:115) duplicated block id: 36 size: 19 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/InputTypeSpec.scala (45:67) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/InputTypeSpec.scala (45:67) duplicated block id: 37 size: 19 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils/UserDefinedFunctionUtils.scala (424:446) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala (212:234) duplicated block id: 38 size: 19 cleaned lines of code in 2 files: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormat.java (126:149) - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java (169:192) duplicated block id: 39 size: 19 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2270:2290) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2559:2579) duplicated block id: 40 size: 18 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalWindowAggregateRuleBase.scala (261:282) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/common/LogicalWindowAggregateRule.scala (274:295) duplicated block id: 41 size: 18 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/SelectivityEstimator.scala (78:98) - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/AggCallSelectivityEstimator.scala (168:188) duplicated block id: 42 size: 18 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java (249:274) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java (295:321) duplicated block id: 43 size: 18 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java (110:136) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java (110:136) duplicated block id: 44 size: 18 cleaned lines of code in 2 files: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseLookupFunction.java (125:146) - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataLookupFunction.java (127:148) duplicated block id: 45 size: 18 cleaned lines of code in 3 files: - flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReusingBuildSecondReOpenableHashJoinIterator.java (40:61) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/NonReusingBuildSecondReOpenableHashJoinIterator.java (40:61) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/NonReusingBuildFirstReOpenableHashJoinIterator.java (40:61) duplicated block id: 46 size: 17 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (676:694) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (648:666) duplicated block id: 47 size: 17 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (767:785) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (739:757) duplicated block id: 48 size: 17 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (988:1006) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (960:978) duplicated block id: 49 size: 17 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/BaseHybridHashTable.java (314:333) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java (1394:1413) duplicated block id: 50 size: 17 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PythonCorrelateSplitRule.java (61:81) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/rules/logical/PythonCorrelateSplitRule.java (63:83) duplicated block id: 51 size: 17 cleaned lines of code in 2 files: - flink-core/src/main/java/org/apache/flink/types/Record.java (1380:1400) - flink-core/src/main/java/org/apache/flink/core/memory/DataInputDeserializer.java (198:218) duplicated block id: 52 size: 16 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (722:739) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (694:711) duplicated block id: 53 size: 16 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (813:830) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (785:802) duplicated block id: 54 size: 16 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PythonCorrelateSplitRule.java (192:212) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/rules/logical/PythonCorrelateSplitRule.java (199:219) duplicated block id: 55 size: 16 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTemporalJoin.scala (391:411) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamTemporalJoinToCoProcessTranslator.scala (214:234) duplicated block id: 56 size: 16 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalMatch.scala (68:85) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalMatch.scala (67:84) duplicated block id: 57 size: 16 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/MatchUtil.scala (32:50) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/util/MatchUtil.scala (31:49) duplicated block id: 58 size: 16 cleaned lines of code in 2 files: - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala (767:828) - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala (737:798) duplicated block id: 59 size: 16 cleaned lines of code in 2 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/undirected/EdgeMetrics.java (311:332) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/directed/EdgeMetrics.java (338:359) duplicated block id: 60 size: 16 cleaned lines of code in 2 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/BulkPartialSolutionPlanNode.java (109:126) - flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/WorksetPlanNode.java (113:130) duplicated block id: 61 size: 15 cleaned lines of code in 2 files: - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java (453:470) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/internal/StreamTableEnvironmentImpl.java (154:171) duplicated block id: 62 size: 15 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java (461:479) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java (352:370) duplicated block id: 63 size: 15 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/utils/python/PythonTableUtils.scala (434:454) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/util/python/PythonTableUtils.scala (378:398) duplicated block id: 64 size: 15 cleaned lines of code in 2 files: - flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java (82:98) - flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowWriteAheadSink.java (83:99) duplicated block id: 65 size: 15 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java (71:91) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java (71:91) duplicated block id: 66 size: 15 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java (328:351) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java (349:372) duplicated block id: 67 size: 15 cleaned lines of code in 3 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (52:69) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSource.java (55:72) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicSource.java (55:72) duplicated block id: 68 size: 15 cleaned lines of code in 3 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/BulkPartialSolutionPlanNode.java (52:73) - flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/WorksetPlanNode.java (52:73) - flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SolutionSetPlanNode.java (51:72) duplicated block id: 69 size: 15 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1309:1325) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1438:1454) duplicated block id: 70 size: 15 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/TaskCheckpointStatisticDetailsHandler.java (64:80) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/CheckpointStatisticDetailsHandler.java (53:69) duplicated block id: 71 size: 14 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java (385:400) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/QueryOperationConverter.java (328:343) duplicated block id: 72 size: 14 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java (482:498) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java (373:389) duplicated block id: 73 size: 14 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java (587:603) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java (436:452) duplicated block id: 74 size: 14 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalCorrelate.scala (45:61) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalCorrelate.scala (40:56) duplicated block id: 75 size: 14 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/Indenter.scala (21:38) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/Indenter.scala (21:38) duplicated block id: 76 size: 14 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/fieldExpression.scala (121:138) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/fieldExpression.scala (182:199) duplicated block id: 77 size: 14 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSlideWindowAggReduceGroupFunction.scala (62:78) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggReduceGroupFunction.scala (71:87) duplicated block id: 78 size: 14 cleaned lines of code in 2 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/GlobalClusteringCoefficient.java (159:178) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/GlobalClusteringCoefficient.java (160:179) duplicated block id: 79 size: 14 cleaned lines of code in 2 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/AverageClusteringCoefficient.java (172:191) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/AverageClusteringCoefficient.java (172:191) duplicated block id: 80 size: 14 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java (47:63) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java (47:63) duplicated block id: 81 size: 14 cleaned lines of code in 2 files: - flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVector.java (137:152) - flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/vector/AbstractOrcNoHiveVector.java (134:149) duplicated block id: 82 size: 14 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1154:1170) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1283:1299) duplicated block id: 83 size: 14 cleaned lines of code in 2 files: - flink-metrics/flink-metrics-influxdb/src/main/java/org/apache/flink/metrics/influxdb/AbstractReporter.java (74:89) - flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/reporter/AbstractReporter.java (67:82) duplicated block id: 84 size: 13 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidator.java (71:87) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/calcite/FlinkCalciteSqlValidator.java (52:68) duplicated block id: 85 size: 13 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala (369:391) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/calcite/FlinkTypeFactory.scala (335:357) duplicated block id: 86 size: 13 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/RexNodeExtractor.scala (281:296) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/util/RexProgramExtractor.scala (329:343) duplicated block id: 87 size: 13 cleaned lines of code in 2 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/TriadicCensus.java (223:241) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/TriadicCensus.java (541:559) duplicated block id: 88 size: 13 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (39:53) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSink.java (41:55) duplicated block id: 89 size: 13 cleaned lines of code in 2 files: - flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVector.java (154:168) - flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/vector/AbstractOrcNoHiveVector.java (151:165) duplicated block id: 90 size: 13 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1673:1687) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1905:1919) duplicated block id: 91 size: 13 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1760:1774) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1992:2006) duplicated block id: 92 size: 13 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2202:2216) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2491:2505) duplicated block id: 93 size: 13 cleaned lines of code in 2 files: - flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputUdfOperator.java (97:114) - flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java (94:111) duplicated block id: 94 size: 13 cleaned lines of code in 2 files: - flink-java/src/main/java/org/apache/flink/api/java/operators/JoinOperator.java (280:300) - flink-java/src/main/java/org/apache/flink/api/java/operators/CoGroupOperator.java (132:152) duplicated block id: 95 size: 13 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/operators/resettable/SpillingResettableIterator.java (174:191) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/resettable/SpillingResettableMutableObjectIterator.java (113:130) duplicated block id: 96 size: 13 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileChannelInputView.java (101:115) - flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/SeekableFileChannelInputView.java (141:155) duplicated block id: 97 size: 13 cleaned lines of code in 6 files: - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobVertexAccumulatorsHandler.java (44:58) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobConfigHandler.java (48:63) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/CheckpointConfigHandler.java (55:69) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobExceptionsHandler.java (57:72) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobAccumulatorsHandler.java (54:68) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtasksTimesHandler.java (53:67) duplicated block id: 98 size: 12 cleaned lines of code in 2 files: - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/operations/JavaDataStreamQueryOperation.java (95:109) - flink-table/flink-table-api-scala-bridge/src/main/java/org/apache/flink/table/operations/ScalaDataStreamQueryOperation.java (93:107) duplicated block id: 99 size: 12 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java (244:257) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/QueryOperationConverter.java (206:219) duplicated block id: 100 size: 12 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java (570:583) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/QueryOperationConverter.java (466:479) duplicated block id: 101 size: 12 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerTypeInferenceUtilImpl.java (121:134) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/expressions/PlannerTypeInferenceUtilImpl.java (116:129) duplicated block id: 102 size: 12 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/PreValidateReWriter.scala (251:264) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/calcite/PreValidateReWriter.scala (188:201) duplicated block id: 103 size: 12 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSort.scala (68:81) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalSort.scala (56:69) duplicated block id: 104 size: 12 cleaned lines of code in 4 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala (82:96) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowTableAggregate.scala (74:89) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/logical/rel/LogicalWindowTableAggregate.scala (69:83) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/logical/rel/LogicalWindowAggregate.scala (86:100) duplicated block id: 105 size: 12 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java (71:87) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java (68:84) duplicated block id: 106 size: 12 cleaned lines of code in 3 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/GlobalClusteringCoefficient.java (57:76) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/TriadicCensus.java (59:78) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/GlobalClusteringCoefficient.java (57:76) duplicated block id: 107 size: 12 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java (213:226) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java (201:214) duplicated block id: 108 size: 12 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactory.java (250:263) - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/index/IndexGeneratorFactory.java (253:266) duplicated block id: 109 size: 12 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java (308:321) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java (338:351) duplicated block id: 110 size: 12 cleaned lines of code in 2 files: - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/AbstractPythonTableFunctionOperator.java (61:74) - flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/PythonTableFunctionFlatMap.java (72:85) duplicated block id: 111 size: 12 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1988:2005) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2275:2292) duplicated block id: 112 size: 12 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2043:2061) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2330:2348) duplicated block id: 113 size: 12 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2302:2315) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2591:2604) duplicated block id: 114 size: 12 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2334:2349) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2623:2638) duplicated block id: 115 size: 12 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2358:2373) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2647:2662) duplicated block id: 116 size: 12 cleaned lines of code in 3 files: - flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReusingBuildFirstReOpenableHashJoinIterator.java (64:79) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReusingBuildSecondReOpenableHashJoinIterator.java (64:79) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/NonReusingBuildFirstReOpenableHashJoinIterator.java (64:79) duplicated block id: 117 size: 11 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/SortMergeOneSideOuterJoinIterator.java (35:47) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/SortMergeInnerJoinIterator.java (35:47) duplicated block id: 118 size: 11 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (118:132) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/MapSerializer.java (126:140) duplicated block id: 119 size: 11 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java (228:241) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/QueryOperationConverter.java (190:203) duplicated block id: 120 size: 11 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java (507:521) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java (658:672) duplicated block id: 121 size: 11 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java (606:618) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java (455:467) duplicated block id: 122 size: 11 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecSortLimit.scala (88:100) - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecSortLimit.scala (87:99) duplicated block id: 123 size: 11 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPythonBase.scala (94:106) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/CommonPythonBase.scala (104:116) duplicated block id: 124 size: 11 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeInfoCheckUtils.scala (80:92) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/typeutils/TypeCheckUtils.scala (207:219) duplicated block id: 125 size: 11 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/Indenter.scala (41:53) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/Indenter.scala (41:53) duplicated block id: 126 size: 11 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/aggregations.scala (57:71) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/aggregations.scala (59:73) duplicated block id: 127 size: 11 cleaned lines of code in 7 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/DoubleValueArray.java (349:364) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/CharValueArray.java (348:363) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ShortValueArray.java (348:363) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ByteValueArray.java (348:363) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/IntValueArray.java (346:361) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/LongValueArray.java (347:362) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/FloatValueArray.java (348:363) duplicated block id: 128 size: 11 cleaned lines of code in 2 files: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java (120:132) - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcLookupFunction.java (124:136) duplicated block id: 129 size: 11 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (935:947) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (724:736) duplicated block id: 130 size: 11 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1679:1693) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1422:1436) duplicated block id: 131 size: 11 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java (287:302) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java (332:347) duplicated block id: 132 size: 11 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka011TableSink.java (37:49) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka010TableSink.java (36:48) duplicated block id: 133 size: 11 cleaned lines of code in 2 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/util/Utils.java (93:108) - flink-optimizer/src/main/java/org/apache/flink/optimizer/postpass/JavaApiPostPass.java (289:304) duplicated block id: 134 size: 11 cleaned lines of code in 2 files: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (345:357) - flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java (411:423) duplicated block id: 135 size: 11 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1572:1584) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1804:1816) duplicated block id: 136 size: 11 cleaned lines of code in 2 files: - flink-runtime-web/web-dashboard/src/app/pages/task-manager/list/task-manager-list.component.ts (46:58) - flink-runtime-web/web-dashboard/src/app/pages/job/overview/taskmanagers/job-overview-drawer-taskmanagers.component.ts (48:60) duplicated block id: 137 size: 11 cleaned lines of code in 3 files: - flink-java/src/main/java/org/apache/flink/api/java/operators/ReduceOperator.java (89:106) - flink-java/src/main/java/org/apache/flink/api/java/operators/GroupCombineOperator.java (93:111) - flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java (183:200) duplicated block id: 138 size: 10 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (182:193) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (161:172) duplicated block id: 139 size: 10 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (187:199) - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (175:187) duplicated block id: 140 size: 10 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (157:171) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/MapSerializer.java (165:179) duplicated block id: 141 size: 10 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/SelectTableSinkBase.java (89:101) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sinks/StreamSelectTableSink.java (94:107) duplicated block id: 142 size: 10 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlCreateTableConverter.java (160:171) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java (268:279) duplicated block id: 143 size: 10 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPlannerImpl.scala (64:75) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/calcite/FlinkPlannerImpl.scala (63:74) duplicated block id: 144 size: 10 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.scala (347:365) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverter.scala (379:397) duplicated block id: 145 size: 10 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPythonBase.scala (139:150) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/CommonPythonBase.scala (162:173) duplicated block id: 146 size: 10 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/PythonCalcSplitRule.scala (355:366) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/PythonCalcSplitRule.scala (355:366) duplicated block id: 147 size: 10 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/fieldExpression.scala (161:172) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/fieldExpression.scala (222:233) duplicated block id: 148 size: 10 cleaned lines of code in 4 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetFinalAggFunction.scala (46:58) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetPreAggFunction.scala (47:59) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetTumbleCountWindowAggReduceGroupFunction.scala (49:61) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetAggFunction.scala (46:58) duplicated block id: 149 size: 10 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java (312:325) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (686:699) duplicated block id: 150 size: 10 cleaned lines of code in 4 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java (101:116) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessWindowFunction.java (120:134) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java (98:113) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessAllWindowFunction.java (122:136) duplicated block id: 151 size: 10 cleaned lines of code in 2 files: - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvOutputFormat.java (109:122) - flink-java/src/main/java/org/apache/flink/api/java/io/CsvOutputFormat.java (107:120) duplicated block id: 152 size: 10 cleaned lines of code in 2 files: - flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java (122:138) - flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java (122:138) duplicated block id: 153 size: 10 cleaned lines of code in 8 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/DoubleValueArray.java (103:120) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/StringValueArray.java (121:138) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/CharValueArray.java (103:120) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ShortValueArray.java (103:120) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ByteValueArray.java (103:120) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/IntValueArray.java (101:118) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/LongValueArray.java (102:119) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/FloatValueArray.java (103:120) duplicated block id: 154 size: 10 cleaned lines of code in 2 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/AverageClusteringCoefficient.java (61:76) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/AverageClusteringCoefficient.java (61:76) duplicated block id: 155 size: 10 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (243:254) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (243:254) duplicated block id: 156 size: 10 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactory.java (218:229) - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/index/IndexGeneratorFactory.java (221:232) duplicated block id: 157 size: 10 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java (154:165) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java (208:219) duplicated block id: 158 size: 10 cleaned lines of code in 2 files: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowInputFormat.java (90:101) - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataInputFormat.java (88:99) duplicated block id: 159 size: 10 cleaned lines of code in 2 files: - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/AbstractStatelessFunctionOperator.java (153:164) - flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/AbstractPythonStatelessFunctionFlatMap.java (331:342) duplicated block id: 160 size: 10 cleaned lines of code in 2 files: - flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVector.java (124:135) - flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/vector/AbstractOrcNoHiveVector.java (121:132) duplicated block id: 161 size: 10 cleaned lines of code in 2 files: - flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVector.java (170:181) - flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/vector/AbstractOrcNoHiveVector.java (167:178) duplicated block id: 162 size: 10 cleaned lines of code in 2 files: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java (341:356) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java (617:632) duplicated block id: 163 size: 10 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2841:2852) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (3394:3405) duplicated block id: 164 size: 10 cleaned lines of code in 2 files: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/EitherSerializerSnapshot.java (83:94) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArraySerializerConfigSnapshot.java (89:100) duplicated block id: 165 size: 10 cleaned lines of code in 3 files: - flink-core/src/main/java/org/apache/flink/api/common/operators/base/GroupReduceOperatorBase.java (138:149) - flink-core/src/main/java/org/apache/flink/api/common/operators/base/ReduceOperatorBase.java (167:178) - flink-core/src/main/java/org/apache/flink/api/common/operators/base/PartitionOperatorBase.java (95:106) duplicated block id: 166 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (498:508) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (470:480) duplicated block id: 167 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (529:539) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (501:511) duplicated block id: 168 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (1008:1018) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (980:990) duplicated block id: 169 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (1187:1197) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (1021:1031) duplicated block id: 170 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/MurmurHashUtils.java (104:114) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/MurmurHashUtil.java (98:108) duplicated block id: 171 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java (417:429) - flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java (598:610) duplicated block id: 172 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java (517:528) - flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java (617:628) duplicated block id: 173 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java (272:282) - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/MapDataSerializer.java (188:198) duplicated block id: 174 size: 9 cleaned lines of code in 2 files: - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterTableProperties.java (58:68) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterViewProperties.java (54:64) duplicated block id: 175 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/PlannerContext.java (255:265) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/PlanningConfigurationBuilder.java (185:195) duplicated block id: 176 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/TemporalJoinUtil.scala (69:79) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/logical/rel/LogicalTemporalTableJoin.scala (114:124) duplicated block id: 177 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamExecMatchRule.scala (108:118) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamMatchRule.scala (101:111) duplicated block id: 178 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/WindowAggregateReduceFunctionsRule.scala (65:77) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/common/WindowAggregateReduceFunctionsRule.scala (65:77) duplicated block id: 179 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/call.scala (54:76) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/call.scala (48:70) duplicated block id: 180 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamCorrelateRule.scala (38:53) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetCorrelateRule.scala (37:52) duplicated block id: 181 size: 9 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetTumbleTimeWindowAggReduceCombineFunction.scala (63:74) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSlideWindowAggReduceCombineFunction.scala (64:75) duplicated block id: 182 size: 9 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java (688:702) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java (433:447) duplicated block id: 183 size: 9 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java (183:194) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithNonKeyedOperator.java (149:160) duplicated block id: 184 size: 9 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java (279:290) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithNonKeyedOperator.java (228:239) duplicated block id: 185 size: 9 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (712:724) - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (386:398) duplicated block id: 186 size: 9 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (795:805) - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (424:434) duplicated block id: 187 size: 9 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java (60:70) - flink-java/src/main/java/org/apache/flink/api/java/LocalEnvironment.java (59:70) duplicated block id: 188 size: 9 cleaned lines of code in 7 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/DoubleValueArray.java (123:134) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/CharValueArray.java (123:134) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ShortValueArray.java (123:134) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ByteValueArray.java (123:134) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/IntValueArray.java (121:132) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/LongValueArray.java (122:133) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/FloatValueArray.java (123:134) duplicated block id: 189 size: 9 cleaned lines of code in 3 files: - flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/StateBootstrapOperator.java (69:80) - flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/BroadcastStateBootstrapOperator.java (72:83) - flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/KeyedStateBootstrapOperator.java (84:95) duplicated block id: 190 size: 9 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (230:240) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (230:240) duplicated block id: 191 size: 9 cleaned lines of code in 2 files: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseReadWriteHelper.java (117:127) - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseSerde.java (189:199) duplicated block id: 192 size: 9 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1405:1416) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1534:1545) duplicated block id: 193 size: 9 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2231:2241) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2520:2530) duplicated block id: 194 size: 9 cleaned lines of code in 2 files: - flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java (57:68) - flink-clients/src/main/java/org/apache/flink/client/program/StreamContextEnvironment.java (61:72) duplicated block id: 195 size: 9 cleaned lines of code in 2 files: - flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarUploadHandler.java (58:68) - flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarDeleteHandler.java (55:65) duplicated block id: 196 size: 9 cleaned lines of code in 2 files: - flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputUdfOperator.java (267:278) - flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java (200:211) duplicated block id: 197 size: 9 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileChannelInputView.java (118:133) - flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/SeekableFileChannelInputView.java (158:173) duplicated block id: 198 size: 9 cleaned lines of code in 3 files: - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobVertexTaskManagersHandler.java (67:77) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtaskCurrentAttemptDetailsHandler.java (50:62) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtaskExecutionAttemptDetailsHandler.java (73:85) duplicated block id: 199 size: 9 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobsOverviewHandler.java (51:61) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobIdsHandler.java (43:53) duplicated block id: 200 size: 8 cleaned lines of code in 2 files: - flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosSessionClusterEntrypoint.java (84:94) - flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosJobClusterEntrypoint.java (87:97) duplicated block id: 201 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (510:520) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (482:492) duplicated block id: 202 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (541:551) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (513:523) duplicated block id: 203 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (664:674) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (636:646) duplicated block id: 204 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (710:720) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (682:692) duplicated block id: 205 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (755:765) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (727:737) duplicated block id: 206 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (801:811) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (773:783) duplicated block id: 207 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (846:856) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (818:828) duplicated block id: 208 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (872:882) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (844:854) duplicated block id: 209 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (898:908) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (870:880) duplicated block id: 210 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (924:934) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (896:906) duplicated block id: 211 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (950:960) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (922:932) duplicated block id: 212 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (976:986) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (948:958) duplicated block id: 213 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/StringUtf8Utils.java (215:224) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StringUtf8Utils.java (212:221) duplicated block id: 214 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/MurmurHashUtils.java (116:125) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/MurmurHashUtil.java (110:119) duplicated block id: 215 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/MurmurHashUtils.java (127:136) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/MurmurHashUtil.java (121:130) duplicated block id: 216 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (77:88) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (90:101) duplicated block id: 217 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (119:130) - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (107:118) duplicated block id: 218 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/operations/JavaDataStreamQueryOperation.java (66:75) - flink-table/flink-table-api-scala-bridge/src/main/java/org/apache/flink/table/operations/ScalaDataStreamQueryOperation.java (64:73) duplicated block id: 219 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/PreValidateReWriter.scala (232:241) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/calcite/PreValidateReWriter.scala (169:178) duplicated block id: 220 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala (57:66) - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecLegacyTableSourceScan.scala (69:78) duplicated block id: 221 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPythonBase.scala (108:121) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/CommonPythonBase.scala (118:131) duplicated block id: 222 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalIntersect.scala (50:59) - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalMinus.scala (50:59) duplicated block id: 223 size: 8 cleaned lines of code in 3 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/BatchExecSingleRowJoinRule.scala (60:69) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalJoin.scala (104:113) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetSingleRowJoinRule.scala (56:65) duplicated block id: 224 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala (139:148) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/LogicalCorrelateToTemporalTableJoinRule.scala (133:142) duplicated block id: 225 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/fieldExpression.scala (58:70) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/fieldExpression.scala (62:74) duplicated block id: 226 size: 8 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala (104:117) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalJoinBase.scala (46:58) duplicated block id: 227 size: 8 cleaned lines of code in 3 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java (328:338) - flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputUdfOperator.java (297:307) - flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java (229:239) duplicated block id: 228 size: 8 cleaned lines of code in 2 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java (297:306) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/ScatterGatherIteration.java (340:349) duplicated block id: 229 size: 8 cleaned lines of code in 2 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/LocalClusteringCoefficient.java (306:316) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/LocalClusteringCoefficient.java (316:326) duplicated block id: 230 size: 8 cleaned lines of code in 3 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java (234:243) - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (195:204) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (195:204) duplicated block id: 231 size: 8 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java (257:266) - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (267:276) duplicated block id: 232 size: 8 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java (243:252) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (267:276) duplicated block id: 233 size: 8 cleaned lines of code in 2 files: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormat.java (219:228) - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java (262:271) duplicated block id: 234 size: 8 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorBase.java (39:48) - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/index/IndexGeneratorBase.java (36:45) duplicated block id: 235 size: 8 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1020:1031) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (794:805) duplicated block id: 236 size: 8 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1293:1304) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1038:1049) duplicated block id: 237 size: 8 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1529:1538) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1274:1283) duplicated block id: 238 size: 8 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java (153:164) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java (153:164) duplicated block id: 239 size: 8 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java (176:186) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java (176:186) duplicated block id: 240 size: 8 cleaned lines of code in 2 files: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (169:180) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueComparator.java (142:153) duplicated block id: 241 size: 8 cleaned lines of code in 3 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AbstractJoinDescriptor.java (175:184) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CoGroupDescriptor.java (202:211) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CartesianProductDescriptor.java (100:109) duplicated block id: 242 size: 8 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (612:621) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (646:655) duplicated block id: 243 size: 8 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (707:716) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (745:754) duplicated block id: 244 size: 8 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (980:989) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1104:1113) duplicated block id: 245 size: 8 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1224:1233) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1353:1362) duplicated block id: 246 size: 8 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1277:1286) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1406:1415) duplicated block id: 247 size: 8 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2175:2184) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2464:2473) duplicated block id: 248 size: 8 cleaned lines of code in 2 files: - flink-core/src/main/java/org/apache/flink/types/Record.java (1516:1525) - flink-core/src/main/java/org/apache/flink/core/memory/DataInputDeserializer.java (335:344) duplicated block id: 249 size: 8 cleaned lines of code in 4 files: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArrayComparator.java (42:51) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArrayComparator.java (42:51) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArrayComparator.java (42:51) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArrayComparator.java (42:51) duplicated block id: 250 size: 8 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/iterative/io/SolutionSetUpdateOutputCollector.java (52:61) - flink-runtime/src/main/java/org/apache/flink/runtime/iterative/io/SolutionSetFastUpdateOutputCollector.java (51:60) duplicated block id: 251 size: 8 cleaned lines of code in 3 files: - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerCustomLogHandler.java (46:56) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerLogFileHandler.java (45:54) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerStdoutFileHandler.java (45:54) duplicated block id: 252 size: 7 cleaned lines of code in 3 files: - flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/SqlAlterHiveTable.java (44:52) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowPartitions.java (71:79) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterTable.java (73:81) duplicated block id: 253 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/python/PythonScalarFunction.java (107:115) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/python/PythonTableFunction.java (109:117) duplicated block id: 254 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java (344:352) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java (316:324) duplicated block id: 255 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/StringUtf8Utils.java (119:127) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StringUtf8Utils.java (116:124) duplicated block id: 256 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/MurmurHashUtils.java (94:102) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/MurmurHashUtil.java (88:96) duplicated block id: 257 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/RowTimeRangeUnboundedPrecedingFunction.java (46:54) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/RowTimeRowsUnboundedPrecedingFunction.java (45:53) duplicated block id: 258 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ArrayDataSerializer.java (293:301) - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/ArrayDataSerializer.java (151:159) duplicated block id: 259 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/LongHashPartition.java (709:717) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/BinaryHashPartition.java (539:547) duplicated block id: 260 size: 7 cleaned lines of code in 4 files: - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BlackHoleTableSinkFactory.java (69:77) - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (106:114) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (106:114) - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseDynamicTableSink.java (74:83) duplicated block id: 261 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java (159:168) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/QueryOperationConverter.java (150:159) duplicated block id: 262 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java (576:584) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java (425:433) duplicated block id: 263 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java (758:768) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java (588:598) duplicated block id: 264 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java (796:804) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java (680:688) duplicated block id: 265 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecMatch.scala (122:130) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamMatch.scala (109:117) duplicated block id: 266 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPythonBase.scala (123:131) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/CommonPythonBase.scala (146:154) duplicated block id: 267 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPythonCorrelate.scala (64:72) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/CommonPythonCorrelate.scala (84:92) duplicated block id: 268 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalJoin.scala (51:59) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalJoin.scala (45:54) duplicated block id: 269 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/TemporalJoinUtil.scala (81:89) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/logical/rel/LogicalTemporalTableJoin.scala (126:134) duplicated block id: 270 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamExecMatchRule.scala (141:150) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamMatchRule.scala (133:142) duplicated block id: 271 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/PythonCalcSplitRule.scala (103:118) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/PythonCalcSplitRule.scala (103:118) duplicated block id: 272 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala (55:63) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/LogicalCorrelateToTemporalTableJoinRule.scala (48:56) duplicated block id: 273 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala (70:78) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/LogicalCorrelateToTemporalTableJoinRule.scala (63:71) duplicated block id: 274 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/BatchLogicalWindowAggregateRule.scala (43:54) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetLogicalWindowAggregateRule.scala (37:48) duplicated block id: 275 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/utils/python/PythonTableUtils.scala (269:277) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/util/python/PythonTableUtils.scala (213:221) duplicated block id: 276 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils/UserDefinedFunctionUtils.scala (410:418) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala (198:206) duplicated block id: 277 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCalcBase.scala (45:55) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetCalcBase.scala (43:53) duplicated block id: 278 size: 7 cleaned lines of code in 3 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/StreamTableSourceScan.scala (62:70) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/dataset/BatchTableSourceScan.scala (61:69) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalTableSourceScan.scala (62:70) duplicated block id: 279 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupTableAggProcessFunction.scala (160:169) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunction.scala (171:180) duplicated block id: 280 size: 7 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/aggfunctions/MinAggFunction.scala (67:75) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/aggfunctions/MaxAggFunction.scala (67:75) duplicated block id: 281 size: 7 cleaned lines of code in 2 files: - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/JoinedStreams.scala (63:71) - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/CoGroupedStreams.scala (65:73) duplicated block id: 282 size: 7 cleaned lines of code in 2 files: - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/JoinedStreams.scala (86:94) - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/CoGroupedStreams.scala (88:96) duplicated block id: 283 size: 7 cleaned lines of code in 2 files: - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/JoinedStreams.scala (106:115) - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/CoGroupedStreams.scala (109:117) duplicated block id: 284 size: 7 cleaned lines of code in 2 files: - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala (402:412) - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala (382:392) duplicated block id: 285 size: 7 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java (421:431) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java (786:796) duplicated block id: 286 size: 7 cleaned lines of code in 4 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/LegacyKeyedProcessOperator.java (59:70) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java (61:72) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/LegacyKeyedCoProcessOperator.java (64:75) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java (56:67) duplicated block id: 287 size: 7 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/LegacyKeyedProcessOperator.java (92:100) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java (89:97) duplicated block id: 288 size: 7 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (217:235) - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (171:189) duplicated block id: 289 size: 7 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java (56:65) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingProcessingTimeWindows.java (54:63) duplicated block id: 290 size: 7 cleaned lines of code in 2 files: - flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/AdamicAdar.java (52:60) - flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/HITS.java (44:52) duplicated block id: 291 size: 7 cleaned lines of code in 8 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/DoubleValueArray.java (210:220) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/StringValueArray.java (276:286) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/CharValueArray.java (210:220) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ShortValueArray.java (210:220) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ByteValueArray.java (210:220) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/IntValueArray.java (208:218) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/LongValueArray.java (209:219) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/FloatValueArray.java (210:220) duplicated block id: 292 size: 7 cleaned lines of code in 2 files: - flink-connectors/flink-hcatalog/src/main/java/org/apache/flink/hcatalog/HCatInputFormatBase.java (318:326) - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopInputFormatBase.java (204:212) duplicated block id: 293 size: 7 cleaned lines of code in 2 files: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java (198:206) - flink-runtime/src/main/java/org/apache/flink/runtime/state/JavaSerializer.java (83:91) duplicated block id: 294 size: 7 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (950:958) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (739:747) duplicated block id: 295 size: 7 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1138:1146) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (903:911) duplicated block id: 296 size: 7 cleaned lines of code in 3 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1306:1317) - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java (380:391) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1051:1062) duplicated block id: 297 size: 7 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1625:1633) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1369:1377) duplicated block id: 298 size: 7 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java (184:192) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java (224:232) duplicated block id: 299 size: 7 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java (331:339) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java (361:369) duplicated block id: 300 size: 7 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java (353:361) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java (375:383) duplicated block id: 301 size: 7 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java (367:375) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java (385:393) duplicated block id: 302 size: 7 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java (501:510) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java (565:574) duplicated block id: 303 size: 7 cleaned lines of code in 2 files: - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/RowDataPythonTableFunctionOperator.java (81:89) - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/PythonTableFunctionOperator.java (66:74) duplicated block id: 304 size: 7 cleaned lines of code in 2 files: - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/RowDataPythonTableFunctionOperator.java (124:133) - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/AbstractRowDataPythonScalarFunctionOperator.java (100:109) duplicated block id: 305 size: 7 cleaned lines of code in 7 files: - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/AbstractRowPythonScalarFunctionOperator.java (54:62) - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/RowDataPythonScalarFunctionOperator.java (51:59) - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/AbstractRowDataPythonScalarFunctionOperator.java (67:75) - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/arrow/RowDataArrowPythonScalarFunctionOperator.java (55:63) - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/arrow/ArrowPythonScalarFunctionOperator.java (55:63) - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/PythonScalarFunctionOperator.java (51:59) - flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/PythonScalarFunctionFlatMap.java (55:63) duplicated block id: 306 size: 7 cleaned lines of code in 3 files: - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/arrow/RowDataArrowPythonScalarFunctionOperator.java (126:134) - flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/arrow/ArrowPythonScalarFunctionOperator.java (126:134) - flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/arrow/ArrowPythonScalarFunctionFlatMap.java (120:128) duplicated block id: 307 size: 7 cleaned lines of code in 3 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/ReduceProperties.java (103:111) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceProperties.java (92:101) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java (143:151) duplicated block id: 308 size: 7 cleaned lines of code in 8 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/ReduceProperties.java (121:129) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceProperties.java (115:123) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllGroupReduceProperties.java (58:66) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllGroupWithPartialPreGroupProperties.java (86:94) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/FlatMapDescriptor.java (61:69) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllGroupCombineProperties.java (58:66) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java (165:173) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/PartialGroupProperties.java (77:85) duplicated block id: 309 size: 7 cleaned lines of code in 2 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceProperties.java (104:112) - flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java (154:162) duplicated block id: 310 size: 7 cleaned lines of code in 2 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/GlobalProperties.java (148:157) - flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/RequestedGlobalProperties.java (154:163) duplicated block id: 311 size: 7 cleaned lines of code in 2 files: - flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java (362:370) - flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java (417:425) duplicated block id: 312 size: 7 cleaned lines of code in 2 files: - flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowSerializationSchema.java (123:131) - flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataSerializationSchema.java (122:130) duplicated block id: 313 size: 7 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2854:2862) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (3407:3415) duplicated block id: 314 size: 7 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (2959:2967) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (3512:3520) duplicated block id: 315 size: 7 cleaned lines of code in 2 files: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/TupleComparatorBase.java (148:156) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoComparator.java (164:172) duplicated block id: 316 size: 7 cleaned lines of code in 3 files: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/LocalTimeTypeInfo.java (146:154) - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/SqlTimeTypeInfo.java (144:152) - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicTypeInfo.java (223:231) duplicated block id: 317 size: 7 cleaned lines of code in 2 files: - flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnApplicationClusterEntryPoint.java (108:118) - flink-kubernetes/src/main/java/org/apache/flink/kubernetes/entrypoint/KubernetesApplicationClusterEntrypoint.java (85:95) duplicated block id: 318 size: 7 cleaned lines of code in 2 files: - flink-java/src/main/java/org/apache/flink/api/java/operators/join/JoinOperatorSetsBase.java (145:155) - flink-java/src/main/java/org/apache/flink/api/java/operators/CoGroupOperator.java (469:479) duplicated block id: 319 size: 7 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java (1190:1200) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/CompactingHashTable.java (723:732) duplicated block id: 320 size: 7 cleaned lines of code in 4 files: - flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingMutableToRegularIteratorWrapper.java (94:102) - flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingKeyGroupedIterator.java (235:243) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingKeyGroupedIterator.java (206:214) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingMutableToRegularIteratorWrapper.java (82:90) duplicated block id: 321 size: 7 cleaned lines of code in 4 files: - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AbstractJobVertexHandler.java (62:71) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/CheckpointingStatisticsHandler.java (62:70) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AbstractSubtaskAttemptHandler.java (64:73) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtaskExecutionAttemptAccumulatorsHandler.java (69:78) duplicated block id: 322 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeTemplate.java (281:288) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java (119:126) duplicated block id: 323 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/Schema.java (121:129) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/descriptors/OldCsv.java (171:179) duplicated block id: 324 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/Schema.java (145:153) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/descriptors/OldCsv.java (189:197) duplicated block id: 325 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/StringUtf8Utils.java (129:136) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StringUtf8Utils.java (126:133) duplicated block id: 326 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/MurmurHashUtils.java (158:165) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/MurmurHashUtil.java (152:159) duplicated block id: 327 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/MurmurHashUtils.java (167:174) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/MurmurHashUtil.java (161:168) duplicated block id: 328 size: 6 cleaned lines of code in 7 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java (67:75) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/LegacyKeyedProcessOperator.java (114:122) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java (126:134) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/LegacyKeyedCoProcessOperator.java (129:137) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoProcessOperator.java (101:109) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java (111:119) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java (87:95) duplicated block id: 329 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/BinaryExternalSorter.java (595:603) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/UnilateralSortMerger.java (665:673) duplicated block id: 330 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/BinaryExternalSorter.java (610:617) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/UnilateralSortMerger.java (680:687) duplicated block id: 331 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/internal/InternalWindowProcessFunction.java (135:142) - flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java (639:646) duplicated block id: 332 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RowDataSerializer.java (289:296) - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/RowDataSerializer.java (164:171) duplicated block id: 333 size: 6 cleaned lines of code in 3 files: - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/LongHashPartition.java (538:545) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/BinaryHashPartition.java (448:455) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/HashPartition.java (481:488) duplicated block id: 334 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/CsvTableSinkFactoryBase.java (65:72) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSourceFactoryBase.java (68:75) duplicated block id: 335 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/CalciteParser.java (51:58) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/calcite/CalciteParser.java (49:56) duplicated block id: 336 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java (337:344) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/QueryOperationConverter.java (280:287) duplicated block id: 337 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java (376:383) - flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/QueryOperationConverter.java (319:326) duplicated block id: 338 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/SingleElementIterator.java (50:57) - flink-runtime/src/main/java/org/apache/flink/runtime/util/SingleElementIterator.java (51:58) duplicated block id: 339 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/inference/TypeInferenceReturnInference.java (54:61) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/inference/TypeInferenceOperandInference.java (55:62) duplicated block id: 340 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPythonBase.scala (37:44) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/CommonPythonBase.scala (35:42) duplicated block id: 341 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalSort.scala (52:59) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalSort.scala (46:54) duplicated block id: 342 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalWindowAggregate.scala (85:97) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala (114:126) duplicated block id: 343 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/PythonCalcSplitRule.scala (282:294) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/PythonCalcSplitRule.scala (282:294) duplicated block id: 344 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala (224:231) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/LogicalCorrelateToTemporalTableJoinRule.scala (217:224) duplicated block id: 345 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/utils/python/PythonTableUtils.scala (52:59) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/util/python/PythonTableUtils.scala (50:57) duplicated block id: 346 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils/UserDefinedFunctionUtils.scala (686:693) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala (596:603) duplicated block id: 347 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala (90:97) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala (102:109) duplicated block id: 348 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetIntersect.scala (68:75) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetMinus.scala (68:75) duplicated block id: 349 size: 6 cleaned lines of code in 2 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalIntersect.scala (45:52) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalMinus.scala (45:52) duplicated block id: 350 size: 6 cleaned lines of code in 6 files: - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/match/IterativeConditionRunner.scala (40:47) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/FlatJoinRunner.scala (41:48) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/CRowMapRunner.scala (45:52) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/outerJoinRunners.scala (44:51) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/MapRunner.scala (40:47) - flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/FlatMapRunner.scala (42:49) duplicated block id: 351 size: 6 cleaned lines of code in 2 files: - flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/server/KvStateServerImpl.java (103:110) - flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyImpl.java (97:104) duplicated block id: 352 size: 6 cleaned lines of code in 2 files: - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala (149:157) - flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala (151:158) duplicated block id: 353 size: 6 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/AbstractMultipleInputTransformation.java (45:52) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/LegacySourceTransformation.java (60:67) duplicated block id: 354 size: 6 cleaned lines of code in 3 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java (91:98) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java (126:133) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/LegacyKeyedCoProcessOperator.java (94:101) duplicated block id: 355 size: 6 cleaned lines of code in 3 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java (101:108) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java (136:143) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/LegacyKeyedCoProcessOperator.java (104:111) duplicated block id: 356 size: 6 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java (121:129) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java (93:101) duplicated block id: 357 size: 6 cleaned lines of code in 5 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/bucketassigners/SimpleVersionedStringSerializer.java (57:64) - flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriter.java (173:180) - flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/S3RecoverableSerializer.java (115:122) - flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableSerializer.java (72:79) - flink-core/src/main/java/org/apache/flink/core/fs/local/LocalRecoverableSerializer.java (71:78) duplicated block id: 358 size: 6 cleaned lines of code in 2 files: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingEventTimeWindows.java (57:65) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java (56:64) duplicated block id: 359 size: 6 cleaned lines of code in 2 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/AdamicAdar.java (294:302) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java (309:317) duplicated block id: 360 size: 6 cleaned lines of code in 2 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/undirected/EdgeMetrics.java (126:134) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/directed/EdgeMetrics.java (119:128) duplicated block id: 361 size: 6 cleaned lines of code in 2 files: - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/undirected/EdgeMetrics.java (301:308) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/directed/EdgeMetrics.java (328:335) duplicated block id: 362 size: 6 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java (229:236) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java (217:224) duplicated block id: 363 size: 6 cleaned lines of code in 3 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7BulkProcessorIndexer.java (57:64) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6BulkProcessorIndexer.java (57:64) - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/PreElasticsearch6BulkProcessorIndexer.java (56:63) duplicated block id: 364 size: 6 cleaned lines of code in 3 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7BulkProcessorIndexer.java (67:74) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6BulkProcessorIndexer.java (67:74) - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/PreElasticsearch6BulkProcessorIndexer.java (66:73) duplicated block id: 365 size: 6 cleaned lines of code in 3 files: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7BulkProcessorIndexer.java (77:84) - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6BulkProcessorIndexer.java (77:84) - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/PreElasticsearch6BulkProcessorIndexer.java (76:83) duplicated block id: 366 size: 6 cleaned lines of code in 2 files: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactory.java (65:72) - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/index/IndexGeneratorFactory.java (64:71) duplicated block id: 367 size: 6 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardHandle.java (47:57) - flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java (54:64) duplicated block id: 368 size: 6 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1386:1393) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1130:1137) duplicated block id: 369 size: 6 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java (71:78) - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java (71:78) duplicated block id: 370 size: 6 cleaned lines of code in 2 files: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaPartitionDiscoverer.java (46:54) - flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010PartitionDiscoverer.java (46:54) duplicated block id: 371 size: 6 cleaned lines of code in 3 files: - flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowTimeWriter.java (46:53) - flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/TimeWriter.java (49:56) - flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/TimeFieldReader.java (42:49) duplicated block id: 372 size: 6 cleaned lines of code in 2 files: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/TimestampSerializer.java (75:82) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/SqlTimestampSerializer.java (57:64) duplicated block id: 373 size: 6 cleaned lines of code in 2 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/GlobalProperties.java (77:85) - flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/RequestedGlobalProperties.java (78:85) duplicated block id: 374 size: 6 cleaned lines of code in 2 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/GlobalProperties.java (120:128) - flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/RequestedGlobalProperties.java (112:119) duplicated block id: 375 size: 6 cleaned lines of code in 2 files: - flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/GlobalProperties.java (448:455) - flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/RequestedGlobalProperties.java (440:447) duplicated block id: 376 size: 6 cleaned lines of code in 3 files: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonFormatFactory.java (80:87) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonFormatFactory.java (81:88) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonFormatFactory.java (92:99) duplicated block id: 377 size: 6 cleaned lines of code in 2 files: - flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowSerializationSchema.java (107:116) - flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDeserializationSchema.java (101:110) duplicated block id: 378 size: 6 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (951:958) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1071:1078) duplicated block id: 379 size: 6 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1004:1012) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1128:1136) duplicated block id: 380 size: 6 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1039:1046) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1163:1170) duplicated block id: 381 size: 6 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1202:1209) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1331:1338) duplicated block id: 382 size: 6 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1493:1501) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1622:1630) duplicated block id: 383 size: 6 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1502:1509) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1631:1638) duplicated block id: 384 size: 6 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1663:1670) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1895:1902) duplicated block id: 385 size: 6 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1743:1750) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (1975:1982) duplicated block id: 386 size: 6 cleaned lines of code in 2 files: - flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java (1849:1856) - flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java (2093:2100) duplicated block id: 387 size: 6 cleaned lines of code in 5 files: - flink-core/src/main/java/org/apache/flink/util/UnionIterator.java (70:77) - flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java (198:205) - flink-java/src/main/java/org/apache/flink/api/java/operators/translation/Tuple3UnwrappingIterator.java (73:80) - flink-java/src/main/java/org/apache/flink/api/java/operators/translation/TupleUnwrappingIterator.java (67:74) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/CombiningUnilateralSortMerger.java (594:601) duplicated block id: 388 size: 6 cleaned lines of code in 2 files: - flink-core/src/main/java/org/apache/flink/util/NumberSequenceIterator.java (180:187) - flink-core/src/main/java/org/apache/flink/util/LongValueSequenceIterator.java (184:191) duplicated block id: 389 size: 6 cleaned lines of code in 2 files: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java (230:237) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/TupleTypeInfo.java (88:95) duplicated block id: 390 size: 6 cleaned lines of code in 2 files: - flink-core/src/main/java/org/apache/flink/api/common/operators/DualInputSemanticProperties.java (146:154) - flink-core/src/main/java/org/apache/flink/api/common/operators/SingleInputSemanticProperties.java (102:109) duplicated block id: 391 size: 6 cleaned lines of code in 2 files: - flink-core/src/main/java/org/apache/flink/api/common/operators/base/GroupReduceOperatorBase.java (155:163) - flink-core/src/main/java/org/apache/flink/api/common/operators/base/GroupCombineOperatorBase.java (85:93) duplicated block id: 392 size: 6 cleaned lines of code in 3 files: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/SqlTimeSerializer.java (88:95) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DateSerializer.java (88:95) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/SqlDateSerializer.java (89:96) duplicated block id: 393 size: 6 cleaned lines of code in 2 files: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DateSerializer.java (78:85) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/SqlDateSerializer.java (79:86) duplicated block id: 394 size: 6 cleaned lines of code in 2 files: - flink-core/src/main/java/org/apache/flink/api/common/io/RichInputFormat.java (47:54) - flink-core/src/main/java/org/apache/flink/api/common/io/RichOutputFormat.java (43:50) duplicated block id: 395 size: 6 cleaned lines of code in 2 files: - flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/EmbeddedExecutorServiceLoader.java (54:61) - flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/EmbeddedExecutorFactory.java (55:62) duplicated block id: 396 size: 6 cleaned lines of code in 2 files: - flink-scala-shell/src/main/java/org/apache/flink/api/java/ScalaShellEnvironment.java (54:62) - flink-scala-shell/src/main/java/org/apache/flink/api/java/ScalaShellStreamEnvironment.java (53:61) duplicated block id: 397 size: 6 cleaned lines of code in 2 files: - flink-scala-shell/src/main/java/org/apache/flink/api/java/ScalaShellEnvironment.java (64:71) - flink-scala-shell/src/main/java/org/apache/flink/api/java/ScalaShellStreamEnvironment.java (63:70) duplicated block id: 398 size: 6 cleaned lines of code in 2 files: - flink-java/src/main/java/org/apache/flink/api/java/operators/JoinOperator.java (187:194) - flink-java/src/main/java/org/apache/flink/api/java/operators/CoGroupOperator.java (174:181) duplicated block id: 399 size: 6 cleaned lines of code in 2 files: - flink-java/src/main/java/org/apache/flink/api/java/operators/JoinOperator.java (1034:1042) - flink-java/src/main/java/org/apache/flink/api/java/operators/CrossOperator.java (391:399) duplicated block id: 400 size: 6 cleaned lines of code in 2 files: - flink-java/src/main/java/org/apache/flink/api/java/operators/SortedGrouping.java (190:198) - flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java (186:194) duplicated block id: 401 size: 6 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/AbstractCheckpointStats.java (178:185) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateStats.java (130:137) duplicated block id: 402 size: 6 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/operators/resettable/NonReusingBlockResettableIterator.java (57:64) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/resettable/ReusingBlockResettableIterator.java (45:52) duplicated block id: 403 size: 6 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingMutableToRegularIteratorWrapper.java (79:86) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingMutableToRegularIteratorWrapper.java (67:74) duplicated block id: 404 size: 6 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java (707:714) - flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraph.java (210:217) duplicated block id: 405 size: 6 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/ResultPartitionMetrics.java (123:130) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/InputGateMetrics.java (142:149) duplicated block id: 406 size: 6 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/ResultPartitionMetrics.java (132:139) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/InputGateMetrics.java (151:158) duplicated block id: 407 size: 6 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/ResultPartitionMetrics.java (141:148) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/InputGateMetrics.java (160:167) duplicated block id: 408 size: 6 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/ResultPartitionMetrics.java (150:157) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/InputGateMetrics.java (169:176) duplicated block id: 409 size: 6 cleaned lines of code in 2 files: - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (128:135) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/UserAccumulator.java (47:54)