12 duplicated lines in: - samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java (60:79, 21%) - samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotMetadata.java (57:76, 20%) 9 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (64:75, 36%) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (68:79, 30%) 9 duplicated lines in: - samza-api/src/main/java/org/apache/samza/storage/StateBackendFactory.java (54:62, 39%) - samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreStateBackendFactory.java (76:84, 18%) 9 duplicated lines in: - samza-api/src/main/java/org/apache/samza/storage/StateBackendFactory.java (54:62, 39%) - samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java (92:100, 7%) 8 duplicated lines in: - samza-api/src/main/java/org/apache/samza/system/descriptors/GenericSystemDescriptor.java (50:59, 66%) - samza-core/src/main/java/org/apache/samza/system/descriptors/DelegatingSystemDescriptor.java (58:67, 50%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:204, 6%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:126, 9%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:59, 25%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:73, 16%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:125, 8%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java (90:98, 12%) - samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotMetadata.java (87:95, 11%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:71, 6%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:176, 6%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:76, 18%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java (101:109, 12%) - samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotMetadata.java (98:106, 11%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:60, 22%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:60, 21%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 7 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:91, 14%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308, 6%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:110, 12%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (303:308, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/Partition.java (45:50, 19%) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (303:308, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79, 20%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%)