6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/MinMaxAvgStatistics.java (77:83, 14%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (175:181, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (80:86, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (123:129, 8%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java (65:71, 8%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java (135:141, 11%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java (120:126, 9%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java (100:106, 9%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/MultipleJobsDetails.java (65:71, 22%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java (73:79, 16%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java (193:200, 4%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexAccumulatorsInfo.java (53:59, 24%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/UserAccumulator.java (56:62, 19%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java (276:282, 4%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (187:193, 1%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatistics.java (130:136, 8%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java (265:271, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ClusterConfigurationInfoEntry.java (58:65, 19%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsInfo.java (66:72, 16%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java (294:300, 4%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (87:93, 4%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (97:103, 6%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java (144:150, 6%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java (163:170, 4%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalLocalKeyedStateHandle.java (91:97, 8%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogListInfo.java (52:58, 26%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersion.java (106:112, 8%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateLocation.java (223:229, 6%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java (158:164, 4%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (362:368, 1%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (441:447, 1%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java (495:501, 1%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapter.java (134:142, 8%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java (88:94, 11%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java (67:73, 17%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/ChainedStateHandle.java (102:108, 15%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (152:158, 5%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java (82:88, 5%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (175:181, 2%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (87:93, 2%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java (43:49, 26%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (283:289, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java (233:239, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java (85:91, 11%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryKeyedStateHandle.java (78:84, 12%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java (64:71, 17%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/SlotOffer.java (61:67, 23%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java (49:55, 19%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (227:233, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (273:279, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateObjectCollection.java (157:163, 6%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotStatus.java (100:106, 11%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (141:147, 2%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (398:404, 2%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java (52:59, 28%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (241:247, 2%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java (322:328, 2%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (152:158, 7%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java (81:87, 7%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java (47:53, 35%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java (96:102, 12%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java (160:166, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagersInfo.java (50:56, 28%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/instance/HardwareDescription.java (121:127, 10%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (168:174, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/SubtaskCheckpointStatistics.java (63:69, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (124:130, 7%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java (75:81, 7%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/InputChannelInfo.java (50:56, 23%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionInfo.java (57:63, 19%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java (171:177, 5%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogInfo.java (63:69, 20%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (131:137, 5%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java (149:155, 5%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (100:106, 8%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobIdsWithStatusOverview.java (143:149, 8%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java (64:70, 8%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java (351:357, 2%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (142:148, 6%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java (65:71, 6%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java (135:141, 7%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateInfo.java (96:102, 14%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java (123:129, 7%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (73:79, 6%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java (154:160, 6%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ResultSubpartitionInfo.java (51:57, 23%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateUID.java (52:58, 21%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java (147:153, 6%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (217:223, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java (156:162, 3%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java (82:88, 15%) 6 duplicated lines in: - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%) - flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java (232:238, 4%)