42 duplicated lines in: - flink-core/src/main/java/org/apache/flink/core/memory/DataInputDeserializer.java (251:303, 18%) - flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedInputView.java (440:492, 14%) 29 duplicated lines in: - flink-core/src/main/java/org/apache/flink/core/memory/DataInputDeserializer.java (251:286, 12%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.java (208:241, 14%) 19 duplicated lines in: - flink-core/src/main/java/org/apache/flink/core/memory/DataOutputSerializer.java (286:309, 9%) - flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedOutputView.java (356:379, 8%) 18 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/NothingTypeInfo.java (35:60, 38%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (37:62, 37%) 15 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/base/CoGroupOperatorBase.java (357:381, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/ReusingSortMergeCoGroupIterator.java (109:133, 20%) 15 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/base/CoGroupOperatorBase.java (357:381, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NonReusingSortMergeCoGroupIterator.java (108:132, 20%) 13 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/base/CoGroupOperatorBase.java (385:403, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NonReusingSortMergeCoGroupIterator.java (136:154, 18%) 13 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/base/CoGroupOperatorBase.java (385:403, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/ReusingSortMergeCoGroupIterator.java (137:155, 17%) 12 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Record.java (1447:1459, 1%) - flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedInputView.java (455:467, 4%) 12 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java (326:343, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java (521:538, 4%) 12 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Record.java (1447:1459, 1%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.java (223:234, 5%) 12 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Record.java (1718:1733, 1%) - flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedOutputView.java (360:375, 5%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java (101:116, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (37:51, 22%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/EitherTypeInfo.java (55:69, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (37:51, 22%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/GenericTypeInfo.java (45:59, 16%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (37:51, 22%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ListSerializer.java (140:158, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/ArrayListSerializer.java (110:128, 13%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java (48:62, 14%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (37:51, 22%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/EnumTypeInfo.java (62:76, 18%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (37:51, 22%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicArrayTypeInfo.java (69:83, 11%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (37:51, 22%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java (188:203, 12%) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/CombiningUnilateralSortMerger.java (584:599, 4%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/PrimitiveArrayTypeInfo.java (101:115, 11%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (37:51, 22%) 10 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/CollectionExecutor.java (583:598, 3%) - flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/DirectExecutorService.java (223:238, 7%) 10 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java (187:201, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingKeyGroupedIterator.java (195:209, 10%) 10 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java (187:201, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingKeyGroupedIterator.java (224:238, 8%) 10 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/CollectionExecutor.java (583:598, 3%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DoneFuture.java (40:55, 38%) 9 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Record.java (1474:1484, <1%) - flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedInputView.java (482:492, 3%) 9 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Record.java (1694:1705, <1%) - flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedOutputView.java (336:347, 4%) 9 duplicated lines in: - flink-core/src/main/java/org/apache/flink/core/memory/DataOutputSerializer.java (265:276, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedOutputView.java (336:347, 4%) 9 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Record.java (1461:1471, <1%) - flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedInputView.java (469:479, 3%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java (347:358, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java (542:553, 2%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/core/memory/DataInputDeserializer.java (289:298, 3%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.java (244:252, 3%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/core/memory/DataInputDeserializer.java (302:316, 3%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.java (256:269, 3%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java (81:95, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingKeyGroupedIterator.java (75:89, 8%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java (74:87, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java (90:103, 2%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java (272:283, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/JavaSerializer.java (65:76, 16%) 7 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java (187:198, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/SingleElementIterator.java (55:66, 31%) 7 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java (176:184, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingKeyGroupedIterator.java (184:192, 7%) 7 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/distributions/CommonRangeBoundaries.java (52:62, 19%) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/shipping/OutputEmitter.java (211:220, 5%) 7 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicTypeInfo.java (132:140, 5%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (43:51, 14%) 7 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java (261:270, 3%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java (283:293, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (322:328, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatistics.java (130:136, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (241:247, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java (294:300, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (187:193, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (156:162, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (87:93, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (175:181, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java (88:94, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java (64:71, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/NumberSequenceIterator.java (88:98, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingKeyGroupedIterator.java (195:205, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobIdsWithStatusOverview.java (143:149, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java (123:129, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java (67:73, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java (276:282, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateUID.java (52:58, 21%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/LongValueSequenceIterator.java (92:102, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/SingleElementIterator.java (55:65, 27%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/instance/HardwareDescription.java (121:127, 10%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersion.java (106:112, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (154:160, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateLocation.java (223:229, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (73:79, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ClusterConfigurationInfoEntry.java (58:65, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogListInfo.java (52:58, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/UserAccumulator.java (56:62, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (64:70, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (100:106, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java (96:102, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (141:147, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java (64:71, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (168:174, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogListInfo.java (52:58, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java (82:88, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (233:239, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (63:69, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (283:289, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/SlotOffer.java (61:67, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotStatus.java (100:106, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java (49:55, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogInfo.java (63:69, 20%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java (193:200, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/ChainedStateHandle.java (102:108, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java (135:141, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (175:181, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (87:93, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java (163:170, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (217:223, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/instance/HardwareDescription.java (121:127, 10%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateInfo.java (96:102, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (144:150, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (97:103, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java (147:153, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/NumberSequenceIterator.java (88:98, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingKeyGroupedIterator.java (224:234, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateInfo.java (96:102, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalLocalKeyedStateHandle.java (91:97, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java (135:141, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java (276:282, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapter.java (134:142, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (351:357, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (63:69, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (168:174, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java (265:271, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (398:404, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java (85:91, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (87:93, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (152:158, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (81:87, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (398:404, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ClusterConfigurationInfoEntry.java (58:65, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateObjectCollection.java (157:163, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagersInfo.java (50:56, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateInfo.java (96:102, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (75:81, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (124:130, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (156:162, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (233:239, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (283:289, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (154:160, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (73:79, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java (160:166, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (351:357, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (73:79, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (154:160, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java (120:126, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionInfo.java (57:63, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java (123:129, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/LongValueSequenceIterator.java (92:102, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingMutableToRegularIteratorWrapper.java (71:81, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagersInfo.java (50:56, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (217:223, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatistics.java (130:136, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java (135:141, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java (49:55, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryKeyedStateHandle.java (78:84, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java (64:71, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (232:238, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryKeyedStateHandle.java (78:84, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (152:158, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (81:87, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotStatus.java (100:106, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (351:357, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexAccumulatorsInfo.java (53:59, 24%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateUID.java (52:58, 21%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java (147:153, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java (163:170, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/ChainedStateHandle.java (102:108, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java (49:55, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (87:93, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (65:71, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (142:148, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (73:79, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (154:160, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexAccumulatorsInfo.java (53:59, 24%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (156:162, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java (123:129, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java (88:94, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (64:70, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java (294:300, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (100:106, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java (64:71, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (80:86, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (87:93, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java (120:126, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapter.java (134:142, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapter.java (134:142, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateLocation.java (223:229, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (241:247, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (322:328, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogListInfo.java (52:58, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java (73:79, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java (265:271, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java (67:73, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogInfo.java (63:69, 20%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (149:155, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (131:137, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java (100:106, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (80:86, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (152:158, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (81:87, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/ChainedStateHandle.java (102:108, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (283:289, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java (82:88, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (82:88, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (152:158, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (63:69, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (233:239, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (168:174, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (152:158, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (82:88, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java (82:88, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (124:130, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (75:81, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryKeyedStateHandle.java (78:84, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java (96:102, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (187:193, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (156:162, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java (160:166, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java (96:102, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/instance/HardwareDescription.java (121:127, 10%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Record.java (1461:1467, <1%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.java (236:241, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (232:238, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (141:147, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalLocalKeyedStateHandle.java (91:97, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java (123:129, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (142:148, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (65:71, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java (135:141, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (149:155, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (131:137, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (232:238, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateObjectCollection.java (157:163, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java (294:300, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java (147:153, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (80:86, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java (171:177, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/NothingTypeInfo.java (65:72, 12%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (67:74, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (398:404, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (81:87, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (152:158, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (241:247, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (322:328, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/SlotOffer.java (61:67, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/InputChannelInfo.java (50:56, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java (193:200, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java (73:79, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java (188:198, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/EmptyIterator.java (64:78, 33%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogInfo.java (63:69, 20%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java (43:49, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java (52:59, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java (160:166, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java (160:166, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionInfo.java (57:63, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java (276:282, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java (96:102, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (131:137, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (149:155, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java (67:73, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java (120:126, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java (88:94, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsInfo.java (66:72, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (124:130, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateUID.java (52:58, 21%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java (85:91, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (75:81, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Record.java (1436:1443, <1%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.java (212:219, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (144:150, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (97:103, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogListInfo.java (52:58, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsInfo.java (66:72, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ResultSubpartitionInfo.java (51:57, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/UserAccumulator.java (56:62, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalLocalKeyedStateHandle.java (91:97, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java (88:94, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/InputChannelInfo.java (50:56, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryKeyedStateHandle.java (78:84, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (273:279, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (227:233, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/instance/HardwareDescription.java (121:127, 10%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (64:70, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (100:106, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/MultipleJobsDetails.java (65:71, 22%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java (64:71, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (175:181, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobIdsWithStatusOverview.java (143:149, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java (49:55, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (87:93, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java (147:153, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersion.java (106:112, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java (73:79, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java (294:300, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsInfo.java (66:72, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotStatus.java (100:106, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexAccumulatorsInfo.java (53:59, 24%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java (47:53, 35%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/SlotOffer.java (61:67, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java (47:53, 35%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/instance/HardwareDescription.java (121:127, 10%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java (171:177, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/UserAccumulator.java (56:62, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateUID.java (52:58, 21%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/GenericTypeSerializerConfigSnapshot.java (70:77, 18%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorStateBackendMetaInfo.java (126:133, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (131:137, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (149:155, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java (294:300, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java (52:59, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexAccumulatorsInfo.java (53:59, 24%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (241:247, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalLocalKeyedStateHandle.java (91:97, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (322:328, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java (43:49, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsInfo.java (66:72, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (398:404, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (87:93, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java (52:59, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (154:160, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (232:238, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (73:79, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java (147:153, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (87:93, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (175:181, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java (158:164, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/InputChannelInfo.java (50:56, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (141:147, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java (85:91, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateLocation.java (223:229, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateInfo.java (96:102, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/LongValueSequenceIterator.java (92:102, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingKeyGroupedIterator.java (195:205, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/ChainedStateHandle.java (102:108, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java (64:71, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/EitherTypeInfo.java (95:102, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (67:74, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (141:147, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateObjectCollection.java (157:163, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java (120:126, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/InputChannelInfo.java (50:56, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java (193:200, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/NumberSequenceIterator.java (88:98, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/SingleElementIterator.java (55:65, 27%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java (158:164, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/instance/HardwareDescription.java (121:127, 10%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionInfo.java (57:63, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobIdsWithStatusOverview.java (143:149, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java (47:53, 35%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionInfo.java (57:63, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java (135:141, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (100:106, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (232:238, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (64:70, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatistics.java (130:136, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (63:69, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (168:174, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/InputChannelInfo.java (50:56, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/SlotOffer.java (61:67, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (362:368, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionInfo.java (57:63, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersion.java (106:112, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java (98:104, 3%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java (132:138, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (441:447, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapter.java (134:142, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobIdsWithStatusOverview.java (143:149, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/MultipleJobsDetails.java (65:71, 22%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/MultipleJobsDetails.java (65:71, 22%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (64:70, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (100:106, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobIdsWithStatusOverview.java (143:149, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsInfo.java (66:72, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersion.java (106:112, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (495:501, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java (52:59, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (227:233, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (273:279, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (241:247, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (322:328, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/UserAccumulator.java (56:62, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (232:238, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (187:193, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (398:404, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (141:147, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java (135:141, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java (158:164, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexAccumulatorsInfo.java (53:59, 24%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (141:147, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (233:239, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java (100:106, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/base/OuterJoinOperatorBase.java (245:252, 3%) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/ReusingSortMergeCoGroupIterator.java (90:97, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java (294:300, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (283:289, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/GenericTypeInfo.java (63:70, 9%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (55:62, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateInfo.java (96:102, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (217:223, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java (88:94, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java (120:126, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ResultSubpartitionInfo.java (51:57, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (168:174, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/MinMaxAvgStatistics.java (77:83, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (63:69, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java (171:177, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (232:238, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexAccumulatorsInfo.java (53:59, 24%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateObjectCollection.java (157:163, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexAccumulatorsInfo.java (53:59, 24%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java (163:170, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (65:71, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (154:160, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (73:79, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (123:129, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotStatus.java (100:106, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (65:71, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (123:129, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (142:148, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (152:158, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java (100:106, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (81:87, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java (147:153, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoRegistration.java (144:151, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorStateBackendMetaInfo.java (126:133, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (65:71, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/base/OuterJoinOperatorBase.java (245:252, 3%) - flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NonReusingSortMergeCoGroupIterator.java (89:96, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (144:150, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ResultSubpartitionInfo.java (51:57, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (97:103, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (273:279, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (227:233, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (124:130, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (75:81, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapter.java (134:142, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ClusterConfigurationInfoEntry.java (58:65, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapter.java (134:142, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (398:404, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (82:88, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (322:328, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (152:158, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (241:247, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/SlotOffer.java (61:67, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (81:87, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (152:158, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (124:130, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (75:81, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (82:88, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/SlotOffer.java (61:67, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (152:158, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (142:148, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (65:71, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java (120:126, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (80:86, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (187:193, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/MultipleJobsDetails.java (65:71, 22%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (351:357, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (217:223, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java (82:88, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/MinMaxAvgStatistics.java (77:83, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicArrayTypeInfo.java (87:94, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (55:62, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateObjectCollection.java (157:163, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (495:501, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerConfigSnapshot.java (87:94, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/OperatorInstanceID.java (53:59, 20%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ClusterConfigurationInfoEntry.java (58:65, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (175:181, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (87:93, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateLocation.java (223:229, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobIdsWithStatusOverview.java (143:149, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java (135:141, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (87:93, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (175:181, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java (73:79, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatistics.java (130:136, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java (171:177, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java (135:141, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/ChainedStateHandle.java (102:108, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java (265:271, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogInfo.java (63:69, 20%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryKeyedStateHandle.java (78:84, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (362:368, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (441:447, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsInfo.java (66:72, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java (82:88, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java (135:141, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java (96:102, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (362:368, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java (135:141, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java (135:141, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/ChainedStateHandle.java (102:108, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (441:447, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (187:193, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (495:501, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (80:86, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (362:368, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java (52:59, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/MinMaxAvgStatistics.java (77:83, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java (158:164, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java (187:197, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingMutableToRegularIteratorWrapper.java (71:81, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatistics.java (130:136, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (87:93, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (64:70, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (100:106, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (97:103, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (144:150, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (144:150, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (97:103, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java (158:164, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java (82:88, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateUID.java (52:58, 21%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapter.java (134:142, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalLocalKeyedStateHandle.java (91:97, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (156:162, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (123:129, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (65:71, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (227:233, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (273:279, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateUID.java (52:58, 21%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java (276:282, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/LongValueSequenceIterator.java (92:102, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingMutableToRegularIteratorWrapper.java (83:93, 13%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (156:162, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java (123:129, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (154:160, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (73:79, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (187:193, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagersInfo.java (50:56, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (144:150, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (97:103, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (273:279, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (149:155, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (131:137, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (227:233, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java (73:79, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java (123:129, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/MultipleJobsDetails.java (65:71, 22%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagersInfo.java (50:56, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogListInfo.java (52:58, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java (67:73, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogInfo.java (63:69, 20%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionInfo.java (57:63, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java (193:200, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java (135:141, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java (160:166, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (131:137, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (149:155, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (351:357, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java (88:94, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java (187:197, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingMutableToRegularIteratorWrapper.java (83:93, 13%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java (49:55, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java (133:140, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (43:50, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatistics.java (130:136, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (142:148, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (283:289, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (65:71, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java (85:91, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (233:239, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersion.java (106:112, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (495:501, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java (49:55, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (441:447, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (362:368, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateObjectCollection.java (157:163, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java (43:49, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (80:86, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java (47:53, 35%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (123:129, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (65:71, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java (67:73, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogInfo.java (63:69, 20%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ResultSubpartitionInfo.java (51:57, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/EnumTypeInfo.java (80:87, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (55:62, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/MinMaxAvgStatistics.java (77:83, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java (123:129, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalLocalKeyedStateHandle.java (91:97, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateLocation.java (223:229, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagersInfo.java (50:56, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/instance/HardwareDescription.java (121:127, 10%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ClusterConfigurationInfoEntry.java (58:65, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/NumberSequenceIterator.java (88:98, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingMutableToRegularIteratorWrapper.java (71:81, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalLocalKeyedStateHandle.java (91:97, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (123:129, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (65:71, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java (96:102, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java (73:79, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/MinMaxAvgStatistics.java (77:83, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateInfo.java (96:102, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java (67:73, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicTypeInfo.java (144:151, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (55:62, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/InputChannelInfo.java (50:56, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java (193:200, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotStatus.java (100:106, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java (265:271, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java (73:79, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/MinMaxAvgStatistics.java (77:83, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/PrimitiveArrayTypeInfo.java (119:126, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (55:62, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (152:158, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java (47:53, 35%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (82:88, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/GenericTypeSerializerConfigSnapshot.java (70:77, 18%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/OperatorInstanceID.java (53:59, 20%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (75:81, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogInfo.java (63:69, 20%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (124:130, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java (265:271, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java (163:170, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java (265:271, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/InputChannelInfo.java (50:56, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java (108:115, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java (55:62, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryKeyedStateHandle.java (78:84, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java (160:166, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (142:148, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (65:71, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java (135:141, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionInfo.java (57:63, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (283:289, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (152:158, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java (193:200, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (82:88, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (233:239, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (495:501, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java (193:200, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (441:447, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java (135:141, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersion.java (106:112, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java (171:177, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ResultSubpartitionInfo.java (51:57, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (322:328, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java (67:73, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java (120:126, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (217:223, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (241:247, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryKeyedStateHandle.java (78:84, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (398:404, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateLocation.java (223:229, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagersInfo.java (50:56, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (63:69, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (168:174, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobIdsWithStatusOverview.java (143:149, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (283:289, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (233:239, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateLocation.java (223:229, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java (85:91, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java (43:49, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ResultSubpartitionInfo.java (51:57, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (63:69, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (273:279, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (227:233, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (65:71, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java (147:153, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java (43:49, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (168:174, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (123:129, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateUID.java (52:58, 21%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (80:86, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (362:368, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (441:447, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagersInfo.java (50:56, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (141:147, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (100:106, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (495:501, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (64:70, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java (100:106, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsInfo.java (66:72, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ListSerializer.java (67:80, 9%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/ArrayListSerializer.java (44:53, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (217:223, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java (100:106, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotStatus.java (100:106, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/SlotOffer.java (61:67, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java (52:59, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java (43:49, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/NumberSequenceIterator.java (88:98, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingMutableToRegularIteratorWrapper.java (83:93, 13%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Record.java (1436:1443, <1%) - flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedInputView.java (444:451, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (156:162, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java (276:282, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotStatus.java (100:106, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (142:148, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java (276:282, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (65:71, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (97:103, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (144:150, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (149:155, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (87:93, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (131:137, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java (171:177, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java (47:53, 35%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java (52:59, 28%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java (64:71, 17%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java (88:94, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java (49:55, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (495:501, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/MinMaxAvgStatistics.java (77:83, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerConfigSnapshot.java (87:94, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorStateBackendMetaInfo.java (126:133, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (441:447, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (362:368, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java (265:271, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogListInfo.java (52:58, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java (158:164, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java (85:91, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/UserAccumulator.java (56:62, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (87:93, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/MultipleJobsDetails.java (65:71, 22%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java (100:106, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (87:93, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (175:181, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java (85:91, 11%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java (47:53, 35%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/MultipleJobsDetails.java (65:71, 22%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/UserAccumulator.java (56:62, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java (294:300, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ResultSubpartitionInfo.java (51:57, 23%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/ChainedStateHandle.java (102:108, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java (100:106, 9%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersion.java (106:112, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java (43:49, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java (276:282, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateInfo.java (96:102, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatistics.java (130:136, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java (163:170, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/UserAccumulator.java (56:62, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java (160:166, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/LongValueSequenceIterator.java (92:102, 7%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingKeyGroupedIterator.java (224:234, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java (96:102, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (123:129, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (65:71, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java (171:177, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java (158:164, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoRegistration.java (144:151, 8%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/OperatorInstanceID.java (53:59, 20%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (81:87, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (187:193, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (152:158, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java (82:88, 15%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ClusterConfigurationInfoEntry.java (58:65, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java (163:170, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ClusterConfigurationInfoEntry.java (58:65, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (227:233, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (273:279, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java (163:170, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (351:357, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (75:81, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (82:88, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateObjectCollection.java (157:163, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogListInfo.java (52:58, 26%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (152:158, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (217:223, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (351:357, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (124:130, 7%)