duplicated block id: 1 size: 244 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala (63:447) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala (63:447) duplicated block id: 2 size: 224 cleaned lines of code in 2 files: - samza-yarn/src/main/resources/scalate/WEB-INF/views/index.scaml (1:239) - samza-yarn3/src/main/resources/scalate/WEB-INF/views/index.scaml (1:239) duplicated block id: 3 size: 151 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java (514:774) - samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java (512:772) duplicated block id: 4 size: 128 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java (82:300) - samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java (82:300) duplicated block id: 5 size: 118 cleaned lines of code in 2 files: - samza-yarn/src/main/less/main.less (18:164) - samza-yarn3/src/main/less/main.less (18:164) duplicated block id: 6 size: 111 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java (313:511) - samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java (312:510) duplicated block id: 7 size: 102 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala (37:189) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala (37:189) duplicated block id: 8 size: 97 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/validation/YarnJobValidationTool.java (70:205) - samza-yarn3/src/main/java/org/apache/samza/validation/YarnJobValidationTool.java (70:205) duplicated block id: 9 size: 82 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/config/YarnConfig.java (28:248) - samza-yarn3/src/main/java/org/apache/samza/config/YarnConfig.java (28:248) duplicated block id: 10 size: 58 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala (38:137) - samza-yarn3/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala (38:137) duplicated block id: 11 size: 54 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterLifecycle.scala (43:120) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterLifecycle.scala (43:120) duplicated block id: 12 size: 48 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManager.java (46:129) - samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManager.java (46:129) duplicated block id: 13 size: 48 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaContainerSecurityManager.scala (36:100) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaContainerSecurityManager.scala (36:100) duplicated block id: 14 size: 47 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala (51:124) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala (51:124) duplicated block id: 15 size: 46 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/util/hadoop/HttpFileSystem.scala (39:104) - samza-yarn3/src/main/scala/org/apache/samza/util/hadoop/HttpFileSystem.scala (39:104) duplicated block id: 16 size: 41 cleaned lines of code in 2 files: - samza-yarn/src/main/resources/scalate/WEB-INF/layouts/default.scaml (1:48) - samza-yarn3/src/main/resources/scalate/WEB-INF/layouts/default.scaml (1:48) duplicated block id: 17 size: 40 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/job/yarn/LocalizerResourceMapper.java (41:98) - samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceMapper.java (41:98) duplicated block id: 18 size: 40 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnAppState.java (41:137) - samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnAppState.java (41:137) duplicated block id: 19 size: 38 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterService.scala (41:99) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterService.scala (41:99) duplicated block id: 20 size: 38 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJobUtil.scala (29:105) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJobUtil.scala (29:105) duplicated block id: 21 size: 36 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/webapp/ApplicationMasterRestClient.java (40:109) - samza-yarn3/src/main/java/org/apache/samza/webapp/ApplicationMasterRestClient.java (40:109) duplicated block id: 22 size: 35 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/job/yarn/LocalizerResourceConfig.java (50:100) - samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceConfig.java (50:100) duplicated block id: 23 size: 33 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java (49:89) - samza-yarn3/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java (49:89) duplicated block id: 24 size: 24 cleaned lines of code in 2 files: - samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaExecutor.java (314:344) - samza-tools/src/main/java/org/apache/samza/tools/SamzaSqlConsole.java (114:144) duplicated block id: 25 size: 22 cleaned lines of code in 2 files: - samza-log4j/src/main/java/org/apache/samza/config/Log4jSystemConfig.java (31:88) - samza-log4j2/src/main/java/org/apache/samza/config/Log4jSystemConfig.java (31:88) duplicated block id: 26 size: 20 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/job/yarn/FileSystemImplConfig.java (30:69) - samza-yarn3/src/main/java/org/apache/samza/job/yarn/FileSystemImplConfig.java (30:69) duplicated block id: 27 size: 18 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/storage/NonTransactionalStateTaskRestoreManager.java (334:353) - samza-core/src/main/java/org/apache/samza/storage/TransactionalStateTaskRestoreManager.java (188:207) duplicated block id: 28 size: 18 cleaned lines of code in 2 files: - samza-tools/src/main/java/org/apache/samza/tools/schemas/PageViewEvent.avsc (1:18) - samza-tools/src/main/java/org/apache/samza/tools/schemas/ProfileChangeEvent.avsc (1:18) duplicated block id: 29 size: 17 cleaned lines of code in 2 files: - samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliLoggingSystemFactory.java (61:84) - samza-tools/src/main/java/org/apache/samza/tools/ConsoleLoggingSystemFactory.java (121:144) duplicated block id: 30 size: 16 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala (26:46) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala (26:46) duplicated block id: 31 size: 16 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsManager.java (89:104) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsManager.java (118:133) duplicated block id: 32 size: 15 cleaned lines of code in 2 files: - samza-yarn/src/main/resources/scalate/WEB-INF/views/index.scaml (1:17) - samza-yarn3/src/main/resources/scalate/WEB-INF/layouts/default.scaml (1:17) duplicated block id: 33 size: 15 cleaned lines of code in 2 files: - samza-yarn/src/main/resources/scalate/WEB-INF/layouts/default.scaml (1:17) - samza-yarn/src/main/resources/scalate/WEB-INF/views/index.scaml (1:17) duplicated block id: 34 size: 15 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJobFactory.scala (31:53) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJobFactory.scala (31:53) duplicated block id: 35 size: 15 cleaned lines of code in 2 files: - samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java (165:195) - samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventJsonSerde.java (160:190) duplicated block id: 36 size: 15 cleaned lines of code in 2 files: - samza-yarn3/src/main/resources/scalate/WEB-INF/layouts/default.scaml (1:17) - samza-yarn3/src/main/resources/scalate/WEB-INF/views/index.scaml (1:17) duplicated block id: 37 size: 15 cleaned lines of code in 2 files: - samza-yarn/src/main/resources/scalate/WEB-INF/layouts/default.scaml (1:17) - samza-yarn3/src/main/resources/scalate/WEB-INF/views/index.scaml (1:17) duplicated block id: 38 size: 13 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/impl/BroadcastOperatorImpl.java (74:92) - samza-core/src/main/java/org/apache/samza/operators/impl/PartitionByOperatorImpl.java (95:113) duplicated block id: 39 size: 13 cleaned lines of code in 2 files: - samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java (44:83) - samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventJsonSerde.java (43:82) duplicated block id: 40 size: 13 cleaned lines of code in 2 files: - samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaExecutor.java (348:365) - samza-tools/src/main/java/org/apache/samza/tools/SamzaSqlConsole.java (148:165) duplicated block id: 41 size: 13 cleaned lines of code in 2 files: - samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandHandler.java (493:506) - samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandHandler.java (693:706) duplicated block id: 42 size: 12 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java (60:79) - samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotMetadata.java (57:76) duplicated block id: 43 size: 12 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/util/hadoop/HttpInputStream.scala (27:43) - samza-yarn3/src/main/scala/org/apache/samza/util/hadoop/HttpInputStream.scala (27:43) duplicated block id: 44 size: 11 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala (61:74) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala (52:65) duplicated block id: 45 size: 11 cleaned lines of code in 2 files: - samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsInputDescriptor.java (103:118) - samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsOutputDescriptor.java (90:104) duplicated block id: 46 size: 10 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java (138:153) - samza-core/src/main/java/org/apache/samza/table/remote/RemoteTable.java (188:202) duplicated block id: 47 size: 10 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/batching/DeleteOperation.java (46:70) - samza-core/src/main/java/org/apache/samza/table/batching/GetOperation.java (51:75) duplicated block id: 48 size: 10 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/AppWithGlobalConfigExample.java (55:68) - samza-test/src/main/java/org/apache/samza/example/PageViewCounterExample.java (58:71) duplicated block id: 49 size: 10 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/storage/NonTransactionalStateTaskRestoreManager.java (87:96) - samza-core/src/main/java/org/apache/samza/storage/TransactionalStateTaskRestoreManager.java (93:102) duplicated block id: 50 size: 10 cleaned lines of code in 2 files: - samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java (141:153) - samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventJsonSerde.java (136:148) duplicated block id: 51 size: 10 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/util/ThrottlingExecutor.java (85:99) - samza-core/src/main/java/org/apache/samza/util/ThrottlingScheduler.java (104:118) duplicated block id: 52 size: 10 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCount.java (65:80) - samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerIds.java (107:122) duplicated block id: 53 size: 10 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java (114:123) - samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java (135:144) duplicated block id: 54 size: 10 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala (32:45) - samza-yarn3/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala (32:45) duplicated block id: 55 size: 10 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.java (54:70) - samza-test/src/main/java/org/apache/samza/system/mock/MockSystemAdmin.java (54:70) duplicated block id: 56 size: 10 cleaned lines of code in 2 files: - samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliLoggingSystemFactory.java (88:104) - samza-tools/src/main/java/org/apache/samza/tools/ConsoleLoggingSystemFactory.java (71:86) duplicated block id: 57 size: 10 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java (92:101) - samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreStateBackendFactory.java (76:85) duplicated block id: 58 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:61) - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:206) duplicated block id: 59 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:62) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:73) duplicated block id: 60 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:78) - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:61) duplicated block id: 61 size: 9 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/drain/DrainMonitor.java (231:240) - samza-core/src/main/java/org/apache/samza/drain/DrainUtils.java (112:121) duplicated block id: 62 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:93) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:62) duplicated block id: 63 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:206) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:178) duplicated block id: 64 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:75) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:178) duplicated block id: 65 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:127) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:62) duplicated block id: 66 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:128) - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:93) duplicated block id: 67 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:78) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:62) duplicated block id: 68 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (64:75) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (68:79) duplicated block id: 69 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:128) - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:75) duplicated block id: 70 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:62) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:178) duplicated block id: 71 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:78) - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:93) duplicated block id: 72 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:93) - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:62) duplicated block id: 73 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:73) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:62) duplicated block id: 74 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:127) - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:75) duplicated block id: 75 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:62) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:62) duplicated block id: 76 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:128) - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:206) duplicated block id: 77 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:61) - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:75) duplicated block id: 78 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:75) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:73) duplicated block id: 79 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:206) - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:75) duplicated block id: 80 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:128) - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:61) duplicated block id: 81 size: 9 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java (68:76) - samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreStateBackendFactory.java (54:62) duplicated block id: 82 size: 9 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java (177:190) - samza-core/src/main/java/org/apache/samza/table/remote/RemoteTable.java (231:244) duplicated block id: 83 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:93) - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:127) duplicated block id: 84 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:61) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:62) duplicated block id: 85 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:78) - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:75) duplicated block id: 86 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:128) - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:78) duplicated block id: 87 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:93) - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:206) duplicated block id: 88 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:178) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:62) duplicated block id: 89 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:73) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:178) duplicated block id: 90 size: 9 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTriggerImpl.java (55:69) - samza-core/src/main/java/org/apache/samza/operators/triggers/TimeTriggerImpl.java (55:69) duplicated block id: 91 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:62) - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:75) duplicated block id: 92 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:127) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:73) duplicated block id: 93 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:128) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:73) duplicated block id: 94 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:93) - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:75) duplicated block id: 95 size: 9 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java (278:291) - samza-core/src/main/java/org/apache/samza/table/remote/RemoteTable.java (363:376) duplicated block id: 96 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:78) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:73) duplicated block id: 97 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:62) - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:61) duplicated block id: 98 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:75) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:62) duplicated block id: 99 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:61) - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:127) duplicated block id: 100 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:93) - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:61) duplicated block id: 101 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:128) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:178) duplicated block id: 102 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/storage/StateBackendFactory.java (54:62) - samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreStateBackendFactory.java (76:84) duplicated block id: 103 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/storage/StateBackendFactory.java (54:62) - samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java (92:100) duplicated block id: 104 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:127) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:178) duplicated block id: 105 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:93) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:178) duplicated block id: 106 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:78) - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:206) duplicated block id: 107 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:206) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:62) duplicated block id: 108 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:93) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:73) duplicated block id: 109 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:128) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:62) duplicated block id: 110 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:128) - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:62) duplicated block id: 111 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:62) - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:206) duplicated block id: 112 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:78) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:178) duplicated block id: 113 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:61) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:178) duplicated block id: 114 size: 9 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/job/yarn/LocalizerResourceException.java (21:69) - samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceException.java (21:69) duplicated block id: 115 size: 9 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/BroadcastOperatorSpec.java (33:47) - samza-core/src/main/java/org/apache/samza/operators/spec/OutputOperatorSpec.java (43:61) duplicated block id: 116 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:128) - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:127) duplicated block id: 117 size: 9 cleaned lines of code in 2 files: - samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnResourceManagerFactory.java (32:42) - samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnResourceManagerFactory.java (32:42) duplicated block id: 118 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:78) - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:127) duplicated block id: 119 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:62) - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:127) duplicated block id: 120 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:206) - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:127) duplicated block id: 121 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:206) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:73) duplicated block id: 122 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:78) - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:62) duplicated block id: 123 size: 9 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:61) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:73) duplicated block id: 124 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (199:206) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 125 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (55:62) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 126 size: 8 cleaned lines of code in 2 files: - samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStore.scala (107:119) - samza-kv/src/main/scala/org/apache/samza/storage/kv/SerializedKeyValueStore.scala (129:141) duplicated block id: 127 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 128 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/descriptors/GenericSystemDescriptor.java (50:59) - samza-core/src/main/java/org/apache/samza/system/descriptors/DelegatingSystemDescriptor.java (58:67) duplicated block id: 129 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (121:128) duplicated block id: 130 size: 8 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java (109:119) - samza-core/src/main/java/org/apache/samza/table/remote/RemoteTable.java (168:178) duplicated block id: 131 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (55:62) duplicated block id: 132 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (55:62) duplicated block id: 133 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (55:62) duplicated block id: 134 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (86:93) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 135 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (71:78) - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) duplicated block id: 136 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (199:206) duplicated block id: 137 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (71:78) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 138 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:83) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:72) duplicated block id: 139 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (54:61) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 140 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (55:62) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 141 size: 8 cleaned lines of code in 2 files: - samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaExecutor.java (163:171) - samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaExecutor.java (229:237) duplicated block id: 142 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (120:127) duplicated block id: 143 size: 8 cleaned lines of code in 2 files: - samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStoreMetrics.scala (27:35) - samza-kv/src/main/scala/org/apache/samza/storage/kv/SerializedKeyValueStoreMetrics.scala (26:34) duplicated block id: 144 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (121:128) - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) duplicated block id: 145 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (54:61) duplicated block id: 146 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (66:73) duplicated block id: 147 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (66:73) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 148 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (171:178) duplicated block id: 149 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (54:61) duplicated block id: 150 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (66:73) duplicated block id: 151 size: 8 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java (256:266) - samza-core/src/main/java/org/apache/samza/table/remote/RemoteTable.java (347:357) duplicated block id: 152 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:72) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:79) duplicated block id: 153 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (171:178) duplicated block id: 154 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (121:128) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 155 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (199:206) duplicated block id: 156 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (86:93) - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) duplicated block id: 157 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (70:80) - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (75:85) duplicated block id: 158 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (68:75) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 159 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (55:62) duplicated block id: 160 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (171:178) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 161 size: 8 cleaned lines of code in 2 files: - samza-sql/src/main/java/org/apache/samza/sql/translator/ScanTranslator.java (67:78) - samza-sql/src/main/java/org/apache/samza/sql/translator/ScanTranslator.java (218:229) duplicated block id: 162 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (86:93) duplicated block id: 163 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (120:127) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 164 size: 8 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/batching/DeleteOperation.java (44:61) - samza-core/src/main/java/org/apache/samza/table/batching/UpdateOperation.java (44:61) duplicated block id: 165 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (68:75) duplicated block id: 166 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:83) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:79) duplicated block id: 167 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (68:75) duplicated block id: 168 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) duplicated block id: 169 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (120:127) duplicated block id: 170 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:112) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:159) duplicated block id: 171 size: 8 cleaned lines of code in 2 files: - samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlFilterRemoteJoinRule.java (141:148) - samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlFilterRemoteJoinRule.java (166:173) duplicated block id: 172 size: 8 cleaned lines of code in 2 files: - samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventStringSerde.java (40:59) - samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventStringSerde.java (43:62) duplicated block id: 173 size: 8 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:52) - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (71:78) duplicated block id: 174 size: 7 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java (217:225) - samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java (294:302) duplicated block id: 175 size: 7 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/KeyValueStoreExample.java (57:66) - samza-test/src/main/java/org/apache/samza/example/WindowExample.java (56:65) duplicated block id: 176 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (196:204) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 177 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/table/descriptors/CachingTableDescriptor.java (134:145) - samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java (282:293) duplicated block id: 178 size: 7 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTriggerImpl.java (60:69) - samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceLastMessageTriggerImpl.java (68:77) duplicated block id: 179 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/table/descriptors/CachingTableDescriptor.java (134:145) - samza-api/src/main/java/org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.java (60:70) duplicated block id: 180 size: 7 cleaned lines of code in 2 files: - samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java (236:245) - samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java (274:283) duplicated block id: 181 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/config/MapConfig.java (118:126) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 182 size: 7 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/storage/KafkaNonTransactionalStateTaskBackupManager.scala (39:47) - samza-core/src/main/scala/org/apache/samza/storage/KafkaTransactionalStateTaskBackupManager.scala (40:48) duplicated block id: 183 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementRequestMessage.java (42:48) - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (62:68) duplicated block id: 184 size: 7 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceLastMessageTriggerImpl.java (68:77) - samza-core/src/main/java/org/apache/samza/operators/triggers/TimeTriggerImpl.java (60:69) duplicated block id: 185 size: 7 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/PageViewCounterExample.java (58:67) - samza-test/src/main/java/org/apache/samza/example/WindowExample.java (56:65) duplicated block id: 186 size: 7 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java (171:178) - samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java (264:271) duplicated block id: 187 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/DrainMessage.java (51:59) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 188 size: 7 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/PageViewCounterExample.java (58:67) - samza-test/src/main/java/org/apache/samza/example/RepartitionExample.java (53:62) duplicated block id: 189 size: 7 cleaned lines of code in 2 files: - samza-sql-shell/conf/samza-sql-shell-log4j.xml (1:29) - samza-tools/src/main/resources/log4j.xml (1:19) duplicated block id: 190 size: 7 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/AppWithGlobalConfigExample.java (55:64) - samza-test/src/main/java/org/apache/samza/example/WindowExample.java (56:65) duplicated block id: 191 size: 7 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java (76:82) - samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java (87:93) duplicated block id: 192 size: 7 cleaned lines of code in 2 files: - samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventStringSerde.java (61:68) - samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventStringSerde.java (64:71) duplicated block id: 193 size: 7 cleaned lines of code in 2 files: - samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java (151:157) - samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java (279:285) duplicated block id: 194 size: 7 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/RepartitionExample.java (53:62) - samza-test/src/main/java/org/apache/samza/example/WindowExample.java (56:65) duplicated block id: 195 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStream.java (65:73) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 196 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (117:125) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 197 size: 7 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala (30:44) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala (30:44) duplicated block id: 198 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java (90:98) - samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotMetadata.java (87:95) duplicated block id: 199 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (63:71) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 200 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java (168:176) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 201 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointOldest.java (32:42) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointUpcoming.java (32:42) duplicated block id: 202 size: 7 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/AppWithGlobalConfigExample.java (55:64) - samza-test/src/main/java/org/apache/samza/example/KeyValueStoreExample.java (57:66) duplicated block id: 203 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java (68:76) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 204 size: 7 cleaned lines of code in 2 files: - samza-kv/src/main/scala/org/apache/samza/storage/kv/CachedStore.scala (296:306) - samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStore.scala (122:132) duplicated block id: 205 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java (101:109) - samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotMetadata.java (98:106) duplicated block id: 206 size: 7 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/KeyValueStoreExample.java (57:66) - samza-test/src/main/java/org/apache/samza/example/RepartitionExample.java (53:62) duplicated block id: 207 size: 7 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/AppWithGlobalConfigExample.java (55:64) - samza-test/src/main/java/org/apache/samza/example/RepartitionExample.java (53:62) duplicated block id: 208 size: 7 cleaned lines of code in 2 files: - samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/descriptors/InMemoryTableDescriptor.java (49:58) - samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.java (310:321) duplicated block id: 209 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java (52:60) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 210 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/ControlMessage.java (52:60) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 211 size: 7 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/KeyValueStoreExample.java (57:66) - samza-test/src/main/java/org/apache/samza/example/PageViewCounterExample.java (58:67) duplicated block id: 212 size: 7 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/storage/KafkaNonTransactionalStateTaskBackupManager.scala (80:87) - samza-core/src/main/scala/org/apache/samza/storage/KafkaTransactionalStateTaskBackupManager.scala (85:92) duplicated block id: 213 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/JobModel.java (83:91) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (300:308) duplicated block id: 214 size: 7 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java (94:106) - samza-core/src/main/java/org/apache/samza/execution/RemoteJobPlanner.java (63:75) duplicated block id: 215 size: 7 cleaned lines of code in 2 files: - samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnAppMasterListener.scala (28:66) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnAppMasterListener.scala (28:66) duplicated block id: 216 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/BoundedSSPIterator.java (76:84) - samza-api/src/main/java/org/apache/samza/system/SystemStreamPartitionIterator.java (86:94) duplicated block id: 217 size: 7 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.java (60:70) - samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java (282:293) duplicated block id: 218 size: 7 cleaned lines of code in 2 files: - samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java (351:358) - samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java (404:411) duplicated block id: 219 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 220 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala (36:41) - samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala (53:58) duplicated block id: 221 size: 6 cleaned lines of code in 2 files: - samza-tools/config/eh-consumer-log4j.xml (26:33) - samza-tools/config/generate-kafka-events-log4j.xml (26:33) duplicated block id: 222 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala (36:41) - samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala (62:67) duplicated block id: 223 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 224 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java (96:103) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableWithUpdateOperatorSpec.java (62:69) duplicated block id: 225 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 226 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 227 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 228 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/batching/DeleteOperation.java (38:53) - samza-core/src/main/java/org/apache/samza/table/batching/PutOperation.java (42:57) duplicated block id: 229 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/JoinOperatorSpec.java (102:109) - samza-core/src/main/java/org/apache/samza/operators/spec/StreamTableJoinOperatorSpec.java (68:75) duplicated block id: 230 size: 6 cleaned lines of code in 2 files: - samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliShell.java (210:215) - samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandHandler.java (236:241) duplicated block id: 231 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) duplicated block id: 232 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 233 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 234 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 235 size: 6 cleaned lines of code in 2 files: - samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java (116:129) - samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java (159:172) duplicated block id: 236 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 237 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 238 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 239 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 240 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 241 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 242 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/OutputOperatorSpec.java (54:61) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java (53:60) duplicated block id: 243 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 244 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) duplicated block id: 245 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 246 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 247 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 248 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 249 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 250 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) duplicated block id: 251 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) duplicated block id: 252 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) duplicated block id: 253 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 254 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 255 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 256 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) duplicated block id: 257 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 258 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java (105:110) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (303:308) duplicated block id: 259 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 260 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) duplicated block id: 261 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 262 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 263 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 264 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 265 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 266 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 267 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 268 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 269 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) duplicated block id: 270 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 271 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 272 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 273 size: 6 cleaned lines of code in 2 files: - samza-sql/src/main/java/org/apache/samza/sql/serializers/SamzaSqlRelMessageSerdeFactory.java (56:62) - samza-sql/src/main/java/org/apache/samza/sql/serializers/SamzaSqlRelRecordSerdeFactory.java (57:63) duplicated block id: 274 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 275 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 276 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/execution/JobNodeConfigurationGenerator.java (305:310) - samza-core/src/main/java/org/apache/samza/table/TableConfigGenerator.java (87:92) duplicated block id: 277 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala (89:94) - samza-core/src/main/scala/org/apache/samza/job/local/ThreadJobFactory.scala (82:87) duplicated block id: 278 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) duplicated block id: 279 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 280 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResourceRequest.java (82:87) - samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResourceRequest.java (95:100) duplicated block id: 281 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 282 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 283 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 284 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 285 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) duplicated block id: 286 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 287 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 288 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/BroadcastOperatorSpec.java (40:47) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableWithUpdateOperatorSpec.java (62:69) duplicated block id: 289 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 290 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 291 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 292 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 293 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 294 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 295 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 296 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 297 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 298 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTable.java (193:201) - samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTable.java (180:188) duplicated block id: 299 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 300 size: 6 cleaned lines of code in 2 files: - samza-test/src/main/java/org/apache/samza/example/BroadcastExample.java (49:56) - samza-test/src/main/java/org/apache/samza/example/MergeExample.java (48:55) duplicated block id: 301 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java (83:90) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableWithUpdateOperatorSpec.java (62:69) duplicated block id: 302 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 303 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 304 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 305 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) duplicated block id: 306 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 307 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) duplicated block id: 308 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) duplicated block id: 309 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) duplicated block id: 310 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 311 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 312 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 313 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 314 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 315 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 316 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinator.java (294:299) - samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java (365:370) duplicated block id: 317 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 318 size: 6 cleaned lines of code in 2 files: - samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java (352:359) - samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java (432:439) duplicated block id: 319 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 320 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.java (33:42) - samza-api/src/main/java/org/apache/samza/operators/triggers/TimeTrigger.java (32:41) duplicated block id: 321 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) duplicated block id: 322 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 323 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 324 size: 6 cleaned lines of code in 2 files: - samza-tools/src/main/java/org/apache/samza/tools/EventHubConsoleConsumer.java (80:85) - samza-tools/src/main/java/org/apache/samza/tools/GenerateKafkaEvents.java (94:99) duplicated block id: 325 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 326 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 327 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) duplicated block id: 328 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) duplicated block id: 329 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 330 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 331 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 332 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 333 size: 6 cleaned lines of code in 2 files: - samza-tools/config/eh-consumer-log4j.xml (26:33) - samza-tools/config/samza-sql-console-log4j.xml (26:33) duplicated block id: 334 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (303:308) - samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java (152:157) duplicated block id: 335 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 336 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 337 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 338 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 339 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 340 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 341 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java (83:90) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java (53:60) duplicated block id: 342 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) duplicated block id: 343 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/MergeOperatorSpec.java (42:49) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java (53:60) duplicated block id: 344 size: 6 cleaned lines of code in 2 files: - samza-yarn/src/main/resources/scalate/css/ropa-sans.css (1:6) - samza-yarn3/src/main/resources/scalate/css/ropa-sans.css (1:6) duplicated block id: 345 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 346 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 347 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 348 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 349 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 350 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) duplicated block id: 351 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 352 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) duplicated block id: 353 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 354 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 355 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 356 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) duplicated block id: 357 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/MergeOperatorSpec.java (42:49) - samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java (83:90) duplicated block id: 358 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 359 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 360 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 361 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 362 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 363 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 364 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 365 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/MergeOperatorSpec.java (42:49) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableWithUpdateOperatorSpec.java (62:69) duplicated block id: 366 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 367 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 368 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 369 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 370 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) duplicated block id: 371 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 372 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 373 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) duplicated block id: 374 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadataStore.java (76:87) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java (106:117) duplicated block id: 375 size: 6 cleaned lines of code in 2 files: - samza-tools/config/generate-kafka-events-log4j.xml (26:33) - samza-tools/config/samza-sql-console-log4j.xml (26:33) duplicated block id: 376 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) duplicated block id: 377 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) duplicated block id: 378 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 379 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 380 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 381 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.java (35:44) - samza-api/src/main/java/org/apache/samza/operators/triggers/TimeTrigger.java (32:41) duplicated block id: 382 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 383 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 384 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 385 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 386 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 387 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 388 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) duplicated block id: 389 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 390 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) duplicated block id: 391 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 392 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTable.java (119:127) - samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTable.java (110:118) duplicated block id: 393 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/BroadcastOperatorSpec.java (40:47) - samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java (83:90) duplicated block id: 394 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java (96:103) - samza-core/src/main/java/org/apache/samza/operators/spec/OutputOperatorSpec.java (54:61) duplicated block id: 395 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 396 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 397 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 398 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 399 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 400 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 401 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 402 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/batching/DeleteOperation.java (60:70) - samza-core/src/main/java/org/apache/samza/table/batching/PutOperation.java (64:74) duplicated block id: 403 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 404 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/operators/KV.java (41:50) - samza-api/src/main/java/org/apache/samza/storage/kv/Entry.java (34:43) duplicated block id: 405 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/storage/NonTransactionalStateTaskRestoreManager.java (102:107) - samza-core/src/main/java/org/apache/samza/storage/TransactionalStateTaskRestoreManager.java (107:112) duplicated block id: 406 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java (96:103) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java (53:60) duplicated block id: 407 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/storage/NonTransactionalStateTaskRestoreManager.java (372:385) - samza-core/src/main/java/org/apache/samza/storage/TransactionalStateTaskRestoreManager.java (165:178) duplicated block id: 408 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 409 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 410 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) duplicated block id: 411 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 412 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 413 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 414 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java (224:237) - samza-core/src/main/java/org/apache/samza/coordinator/StreamRegexMonitor.java (208:221) duplicated block id: 415 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 416 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 417 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 418 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) duplicated block id: 419 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 420 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 421 size: 6 cleaned lines of code in 2 files: - samza-kv/src/main/scala/org/apache/samza/storage/kv/CachedStore.scala (297:306) - samza-kv/src/main/scala/org/apache/samza/storage/kv/NullSafeKeyValueStore.scala (102:111) duplicated block id: 422 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/AsyncFlatMapOperatorSpec.java (46:53) - samza-core/src/main/java/org/apache/samza/operators/spec/FlatMapOperatorSpec.java (38:45) duplicated block id: 423 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 424 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala (64:74) - samza-core/src/main/scala/org/apache/samza/job/local/ThreadJobFactory.scala (66:76) duplicated block id: 425 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 426 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) duplicated block id: 427 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 428 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) duplicated block id: 429 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) duplicated block id: 430 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 431 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 432 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) duplicated block id: 433 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 434 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 435 size: 6 cleaned lines of code in 2 files: - samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java (214:219) - samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java (251:256) duplicated block id: 436 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 437 size: 6 cleaned lines of code in 2 files: - samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala (169:175) - samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala (201:207) duplicated block id: 438 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 439 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 440 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) duplicated block id: 441 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 442 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/OutputOperatorSpec.java (54:61) - samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java (83:90) duplicated block id: 443 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 444 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) duplicated block id: 445 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 446 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 447 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 448 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 449 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/BroadcastOperatorSpec.java (40:47) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java (53:60) duplicated block id: 450 size: 6 cleaned lines of code in 2 files: - samza-tools/config/bench-log4j.xml (26:33) - samza-tools/config/generate-kafka-events-log4j.xml (26:33) duplicated block id: 451 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 452 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 453 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 454 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java (85:90) - samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java (109:114) duplicated block id: 455 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/table/ReadWriteTable.java (101:141) - samza-api/src/main/java/org/apache/samza/table/ReadWriteUpdateTable.java (100:140) duplicated block id: 456 size: 6 cleaned lines of code in 2 files: - samza-tools/config/bench-log4j.xml (26:33) - samza-tools/config/eh-consumer-log4j.xml (26:33) duplicated block id: 457 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/ratelimit/AsyncRateLimitedTable.java (158:165) - samza-core/src/main/java/org/apache/samza/table/retry/AsyncRetriableTable.java (156:163) duplicated block id: 458 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 459 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 460 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementRequestAllocator.java (59:64) - samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementRequestAllocator.java (74:79) duplicated block id: 461 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) duplicated block id: 462 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 463 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 464 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) duplicated block id: 465 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/OutputOperatorSpec.java (54:61) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableWithUpdateOperatorSpec.java (62:69) duplicated block id: 466 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 467 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 468 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 469 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 470 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 471 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 472 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 473 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 474 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 475 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 476 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 477 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 478 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 479 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 480 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 481 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 482 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 483 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 484 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java (96:103) - samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java (83:90) duplicated block id: 485 size: 6 cleaned lines of code in 2 files: - samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStore.scala (123:132) - samza-kv/src/main/scala/org/apache/samza/storage/kv/NullSafeKeyValueStore.scala (102:111) duplicated block id: 486 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 487 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 488 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 489 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 490 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 491 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) duplicated block id: 492 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 493 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) duplicated block id: 494 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/BroadcastOperatorSpec.java (40:47) - samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java (96:103) duplicated block id: 495 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/MergeOperatorSpec.java (42:49) - samza-core/src/main/java/org/apache/samza/operators/spec/OutputOperatorSpec.java (54:61) duplicated block id: 496 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) duplicated block id: 497 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java (212:217) - samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java (138:143) duplicated block id: 498 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 499 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadataStore.java (120:125) - samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadataStore.java (139:144) duplicated block id: 500 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 501 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 502 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 503 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 504 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 505 size: 6 cleaned lines of code in 2 files: - samza-tools/config/bench-log4j.xml (26:33) - samza-tools/config/samza-sql-console-log4j.xml (26:33) duplicated block id: 506 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 507 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) duplicated block id: 508 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 509 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 510 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 511 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 512 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 513 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 514 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/BroadcastOperatorSpec.java (40:47) - samza-core/src/main/java/org/apache/samza/operators/spec/MergeOperatorSpec.java (42:49) duplicated block id: 515 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) duplicated block id: 516 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 517 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 518 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) duplicated block id: 519 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 520 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 521 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74) duplicated block id: 522 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) duplicated block id: 523 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/batching/GetOperation.java (51:66) - samza-core/src/main/java/org/apache/samza/table/batching/UpdateOperation.java (46:61) duplicated block id: 524 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 525 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) duplicated block id: 526 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 527 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) duplicated block id: 528 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) duplicated block id: 529 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 530 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) duplicated block id: 531 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84) duplicated block id: 532 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java (53:60) - samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableWithUpdateOperatorSpec.java (62:69) duplicated block id: 533 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153) duplicated block id: 534 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 535 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java (63:69) duplicated block id: 536 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65) duplicated block id: 537 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) duplicated block id: 538 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java (74:80) - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) duplicated block id: 539 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 540 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/Partition.java (45:50) - samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java (303:308) duplicated block id: 541 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.java (35:44) - samza-api/src/main/java/org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.java (33:42) duplicated block id: 542 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 543 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java (128:134) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 544 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76) - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52) duplicated block id: 545 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 546 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java (99:105) - samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java (70:76) duplicated block id: 547 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51) - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79) duplicated block id: 548 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162) duplicated block id: 549 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) duplicated block id: 550 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java (67:73) - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) duplicated block id: 551 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java (62:68) - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) duplicated block id: 552 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java (69:75) duplicated block id: 553 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java (93:99) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 554 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 555 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTable.java (152:160) - samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTable.java (143:151) duplicated block id: 556 size: 6 cleaned lines of code in 2 files: - samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java (79:85) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 557 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java (96:103) - samza-core/src/main/java/org/apache/samza/operators/spec/MergeOperatorSpec.java (42:49) duplicated block id: 558 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java (70:84) - samza-core/src/main/java/org/apache/samza/operators/spec/OutputStreamImpl.java (55:69) duplicated block id: 559 size: 6 cleaned lines of code in 2 files: - samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala (351:357) - samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala (368:374) duplicated block id: 560 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62) - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190) duplicated block id: 561 size: 6 cleaned lines of code in 2 files: - samza-core/src/main/java/org/apache/samza/table/batching/GetOperation.java (65:75) - samza-core/src/main/java/org/apache/samza/table/batching/PutOperation.java (64:74)