6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75, 24%) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105, 14%) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68, 24%) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85, 15%) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69, 21%) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99, 12%) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73, 17%) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76, 18%) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134, 10%) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%) 6 duplicated lines in: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80, 14%) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)