duplicated block id: 1 size: 89 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/core/MQL.java (44:269) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/MQL.java (44:269) duplicated block id: 2 size: 68 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java (245:331) - mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java (195:281) duplicated block id: 3 size: 63 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java (50:129) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java (44:124) duplicated block id: 4 size: 47 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/RemoteRxEvent.java (24:103) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteRxEvent.java (24:103) duplicated block id: 5 size: 43 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (229:281) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (375:427) duplicated block id: 6 size: 42 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/InMemoryStore.java (37:91) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java (101:155) duplicated block id: 7 size: 39 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/WorkerHost.java (28:84) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (28:84) duplicated block id: 8 size: 38 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToGroup.java (62:135) - mantis-runtime/src/main/java/io/mantisrx/runtime/KeyToKey.java (63:137) duplicated block id: 9 size: 37 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java (60:118) - mantis-remote-observable/src/main/java/io/reactivex/netty/codec/Codecs.java (41:99) duplicated block id: 10 size: 32 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerHeartbeat.java (51:102) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerStatus.java (51:103) duplicated block id: 11 size: 28 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java (72:108) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (60:96) duplicated block id: 12 size: 28 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/WorkerAssignments.java (26:69) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerAssignments.java (28:71) duplicated block id: 13 size: 26 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/LeaderElector.java (101:136) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/ZookeeperLeaderElector.java (103:138) duplicated block id: 14 size: 25 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpClientListener.java (139:179) - mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpServerListener.java (136:176) duplicated block id: 15 size: 25 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java (22:49) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (26:53) duplicated block id: 16 size: 24 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (377:405) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (501:530) duplicated block id: 17 size: 24 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/core/MQLQueryManager.java (24:63) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/MQLQueryManager.java (24:63) duplicated block id: 18 size: 24 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/LeaderElector.java (64:97) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/ZookeeperLeaderElector.java (59:92) duplicated block id: 19 size: 24 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisWorkerMetadataWritable.java (200:223) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisWorkerMetadataWritable.java (229:252) duplicated block id: 20 size: 24 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (231:259) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (501:530) duplicated block id: 21 size: 22 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (278:314) - mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (157:193) duplicated block id: 22 size: 22 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (66:90) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (122:146) duplicated block id: 23 size: 22 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (209:238) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (274:303) duplicated block id: 24 size: 21 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java (58:90) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NoopStore.java (31:63) duplicated block id: 25 size: 20 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedDataSourceSink.java (40:68) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedDataSourceSink.java (34:62) duplicated block id: 26 size: 20 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedEventFilter.java (45:72) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedEventFilter.java (40:67) duplicated block id: 27 size: 19 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java (62:82) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java (184:203) duplicated block id: 28 size: 19 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/JobSchedulingInfo.java (29:56) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/JobSchedulingInfo.java (30:57) duplicated block id: 29 size: 18 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/MasterDescriptionRoute.java (76:102) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (87:113) duplicated block id: 30 size: 18 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java (214:238) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java (201:225) duplicated block id: 31 size: 17 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/metrics/GaugeCallback.java (48:74) - mantis-common/src/main/java/io/mantisrx/common/metrics/spectator/GaugeCallback.java (88:113) duplicated block id: 32 size: 17 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/core/TaggedData.java (29:57) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/core/TaggedData.java (28:57) duplicated block id: 33 size: 17 cleaned lines of code in 2 files: - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/Controller.java (37:62) - mantis-rxcontrol/src/main/java/io/mantisrx/control/IController.java (44:69) duplicated block id: 34 size: 17 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java (159:175) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java (195:211) duplicated block id: 35 size: 16 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (407:427) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (532:552) duplicated block id: 36 size: 16 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (77:96) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (209:228) duplicated block id: 37 size: 16 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (77:96) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (274:293) duplicated block id: 38 size: 16 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (261:281) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (532:552) duplicated block id: 39 size: 16 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToGroup.java (80:111) - mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToKey.java (74:105) duplicated block id: 40 size: 16 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (91:112) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteRxServer.java (147:168) duplicated block id: 41 size: 15 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ServeNestedObservable.java (61:83) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ServeObservable.java (76:98) duplicated block id: 42 size: 15 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/DefaultHttpServerProvider.java (74:94) - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/DefaultHttpServerProvider.java (118:138) duplicated block id: 43 size: 15 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java (136:155) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java (209:228) duplicated block id: 44 size: 15 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/MantisWorkerMetadataImpl.java (257:271) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisWorkerMetadataWritable.java (201:215) duplicated block id: 45 size: 15 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/MantisWorkerMetadataImpl.java (257:271) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisWorkerMetadataWritable.java (230:244) duplicated block id: 46 size: 15 cleaned lines of code in 2 files: - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java (189:219) - mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/AgentV2Main.java (119:152) duplicated block id: 47 size: 14 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/Jar.java (39:60) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (315:336) duplicated block id: 48 size: 14 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java (143:156) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java (180:193) duplicated block id: 49 size: 14 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/FilterableMantisJobMetadataWritable.java (40:53) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisJobMetadataWritable.java (92:105) duplicated block id: 50 size: 14 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java (595:609) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java (616:630) duplicated block id: 51 size: 14 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-core/src/testFixtures/java/io/mantisrx/server/core/TestingRpcService.java (134:149) - mantis-control-plane/mantis-control-plane-core/src/testFixtures/java/io/mantisrx/server/core/TestingRpcService.java (157:172) duplicated block id: 52 size: 14 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java (220:242) - mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java (170:192) duplicated block id: 53 size: 14 cleaned lines of code in 2 files: - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/utils/ErrorComputer.java (35:59) - mantis-rxcontrol/src/main/java/io/mantisrx/control/controllers/ErrorComputer.java (33:58) duplicated block id: 54 size: 14 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java (114:129) - mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java (188:203) duplicated block id: 55 size: 13 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (505:522) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteRxServer.java (89:106) duplicated block id: 56 size: 13 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (74:86) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (377:389) duplicated block id: 57 size: 13 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (381:397) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteRxServer.java (89:106) duplicated block id: 58 size: 13 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java (44:61) - mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java (37:54) duplicated block id: 59 size: 13 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/NetworkMerge.java (25:42) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageIn.java (25:42) duplicated block id: 60 size: 13 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/SourceOut.java (25:42) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageOut.java (25:42) duplicated block id: 61 size: 13 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/NetworkMerge.java (25:42) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/SourceOut.java (25:42) duplicated block id: 62 size: 13 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (235:251) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteRxServer.java (89:106) duplicated block id: 63 size: 13 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToScalar.java (82:115) - mantis-runtime/src/main/java/io/mantisrx/runtime/KeyToScalar.java (70:96) duplicated block id: 64 size: 13 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (314:330) - mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (198:214) duplicated block id: 65 size: 13 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/NetworkMerge.java (25:42) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageOut.java (25:42) duplicated block id: 66 size: 13 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageIn.java (25:42) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageOut.java (25:42) duplicated block id: 67 size: 13 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/SourceOut.java (25:42) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageIn.java (25:42) duplicated block id: 68 size: 12 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (39:54) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (342:357) duplicated block id: 69 size: 12 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (60:72) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (363:375) duplicated block id: 70 size: 12 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java (146:157) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java (219:230) duplicated block id: 71 size: 12 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ServerConfig.java (27:38) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ServerConfig.java (105:116) duplicated block id: 72 size: 12 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java (206:218) - mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java (342:354) duplicated block id: 73 size: 12 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/QueryRequestPostProcessor.java (43:57) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/QueryRequestPostProcessor.java (40:56) duplicated block id: 74 size: 12 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1304:1322) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1450:1468) duplicated block id: 75 size: 12 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java (236:248) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (239:250) duplicated block id: 76 size: 12 cleaned lines of code in 2 files: - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/config/StaticPropertiesConfigurationFactory.java (24:40) - mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/config/StaticPropertiesConfigurationFactory.java (23:40) duplicated block id: 77 size: 12 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (711:728) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (774:791) duplicated block id: 78 size: 11 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java (133:147) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java (302:316) duplicated block id: 79 size: 11 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (62:72) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (86:96) duplicated block id: 80 size: 11 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java (183:193) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java (219:229) duplicated block id: 81 size: 11 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/SseSinkConnectionFunction.java (47:62) - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnectionFunction.java (45:59) duplicated block id: 82 size: 11 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (113:125) - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (84:96) duplicated block id: 83 size: 11 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (133:146) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (274:287) duplicated block id: 84 size: 11 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (133:146) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (209:222) duplicated block id: 85 size: 11 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/MasterDescriptionRoute.java (104:120) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (116:132) duplicated block id: 86 size: 11 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ServeNestedObservable.java (107:124) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ServeObservable.java (124:140) duplicated block id: 87 size: 11 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java (183:216) - mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java (133:166) duplicated block id: 88 size: 11 cleaned lines of code in 2 files: - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java (112:122) - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java (128:138) duplicated block id: 89 size: 11 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java (174:190) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java (169:185) duplicated block id: 90 size: 11 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/HeartbeatHandler.java (28:40) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/HeartbeatHandler.java (27:39) duplicated block id: 91 size: 11 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (173:183) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (256:266) duplicated block id: 92 size: 11 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobDiscoveryRoute.java (131:141) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobDiscoveryStreamRoute.java (107:117) duplicated block id: 93 size: 11 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (48:60) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (67:79) duplicated block id: 94 size: 11 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (251:268) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1411:1429) duplicated block id: 95 size: 10 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (451:460) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (470:479) duplicated block id: 96 size: 10 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/DisableBackPressureOperator.java (55:70) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageIn.java (27:40) duplicated block id: 97 size: 10 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryCachingImpl.java (128:142) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryStaticImpl.java (93:107) duplicated block id: 98 size: 10 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java (51:64) - mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java (86:99) duplicated block id: 99 size: 10 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java (60:69) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (653:662) duplicated block id: 100 size: 10 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java (286:295) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (288:297) duplicated block id: 101 size: 10 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (2175:2190) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (2217:2232) duplicated block id: 102 size: 10 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java (123:138) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisStageMetadataWritable.java (81:96) duplicated block id: 103 size: 10 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/DisableBackPressureOperator.java (55:70) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageOut.java (27:40) duplicated block id: 104 size: 10 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java (54:63) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (653:662) duplicated block id: 105 size: 10 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (1516:1525) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (1624:1633) duplicated block id: 106 size: 10 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/DisableBackPressureOperator.java (55:70) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/NetworkMerge.java (27:40) duplicated block id: 107 size: 10 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/SinkClientImpl.java (138:149) - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MetricsClientImpl.java (122:133) duplicated block id: 108 size: 10 cleaned lines of code in 2 files: - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java (279:288) - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java (307:316) duplicated block id: 109 size: 10 cleaned lines of code in 2 files: - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/utils/Derivative.java (24:38) - mantis-rxcontrol/src/main/java/io/mantisrx/control/controllers/Derivative.java (23:35) duplicated block id: 110 size: 10 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobStatusRoute.java (57:68) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/MasterDescriptionRoute.java (163:174) duplicated block id: 111 size: 10 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/DisableBackPressureOperator.java (55:70) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/SourceOut.java (27:40) duplicated block id: 112 size: 10 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (134:143) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (150:159) duplicated block id: 113 size: 10 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java (31:45) - mantis-remote-observable/src/main/java/io/reactivex/netty/codec/Codecs.java (27:41) duplicated block id: 114 size: 10 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/SseSinkConnectionFunction.java (132:146) - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnectionFunction.java (127:141) duplicated block id: 115 size: 10 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java (93:104) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobRoute.java (86:97) duplicated block id: 116 size: 10 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (431:440) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (470:479) duplicated block id: 117 size: 10 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (431:440) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (451:460) duplicated block id: 118 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) duplicated block id: 119 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) duplicated block id: 120 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) duplicated block id: 121 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) duplicated block id: 122 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (500:509) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (712:721) duplicated block id: 123 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 124 size: 9 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToScalar.java (126:142) - mantis-runtime/src/main/java/io/mantisrx/runtime/KeyToScalar.java (96:112) duplicated block id: 125 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 126 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1349:1359) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1496:1506) duplicated block id: 127 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) duplicated block id: 128 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) duplicated block id: 129 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 130 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 131 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 132 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) duplicated block id: 133 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 134 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) duplicated block id: 135 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) duplicated block id: 136 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) duplicated block id: 137 size: 9 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 138 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 139 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) duplicated block id: 140 size: 9 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ConnectToGroupedObservable.java (70:80) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ConnectToObservable.java (63:73) duplicated block id: 141 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) duplicated block id: 142 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) duplicated block id: 143 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) duplicated block id: 144 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (516:524) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (580:588) duplicated block id: 145 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 146 size: 9 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/SinkClientImpl.java (104:118) - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MetricsClientImpl.java (94:108) duplicated block id: 147 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 148 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java (106:114) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisStageMetadataWritable.java (66:74) duplicated block id: 149 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 150 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 151 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) duplicated block id: 152 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 153 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 154 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) duplicated block id: 155 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 156 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 157 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 158 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 159 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) duplicated block id: 160 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) duplicated block id: 161 size: 9 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java (201:210) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java (304:313) duplicated block id: 162 size: 9 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java (83:93) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (631:641) duplicated block id: 163 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) duplicated block id: 164 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (598:607) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (712:721) duplicated block id: 165 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) duplicated block id: 166 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (674:683) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (712:721) duplicated block id: 167 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 168 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (598:607) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (674:683) duplicated block id: 169 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 170 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (598:607) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (636:645) duplicated block id: 171 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) duplicated block id: 172 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 173 size: 9 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java (39:51) - mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java (69:81) duplicated block id: 174 size: 9 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/core/TaggedData.java (61:73) - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/stage/TaggingStage.java (136:148) duplicated block id: 175 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 176 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 177 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) duplicated block id: 178 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/MasterDescriptionRoute.java (61:73) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (66:80) duplicated block id: 179 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 180 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) duplicated block id: 181 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) duplicated block id: 182 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) duplicated block id: 183 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) duplicated block id: 184 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) duplicated block id: 185 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) duplicated block id: 186 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) duplicated block id: 187 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) duplicated block id: 188 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) duplicated block id: 189 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 190 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java (98:106) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java (123:131) duplicated block id: 191 size: 9 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/ChoiceOfTwoEventTransmitter.java (61:69) - mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/RoundRobinEventTransmitter.java (53:62) duplicated block id: 192 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (558:567) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (674:683) duplicated block id: 193 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) duplicated block id: 194 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) duplicated block id: 195 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (636:645) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (674:683) duplicated block id: 196 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (558:567) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (712:721) duplicated block id: 197 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) duplicated block id: 198 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) duplicated block id: 199 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 200 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) duplicated block id: 201 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 202 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (558:567) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (636:645) duplicated block id: 203 size: 9 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java (77:87) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (631:641) duplicated block id: 204 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) duplicated block id: 205 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 206 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java (426:434) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java (439:447) duplicated block id: 207 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) duplicated block id: 208 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java (64:73) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java (83:92) duplicated block id: 209 size: 9 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/ChoiceOfTwoEventTransmitter.java (85:93) - mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/RoundRobinEventTransmitter.java (70:78) duplicated block id: 210 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 211 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (560:568) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (584:592) duplicated block id: 212 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) duplicated block id: 213 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 214 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) duplicated block id: 215 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) duplicated block id: 216 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 217 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 218 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 219 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 220 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) duplicated block id: 221 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) duplicated block id: 222 size: 9 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/stage/TaggingStage.java (136:148) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/AbstractAckableTaggingStage.java (133:145) duplicated block id: 223 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java (337:348) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java (508:518) duplicated block id: 224 size: 9 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/core/TaggedData.java (61:73) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/AbstractAckableTaggingStage.java (133:145) duplicated block id: 225 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 226 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 227 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 228 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 229 size: 9 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/OperatorResumeOnCompleted.java (42:54) - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/OperatorResumeOnError.java (42:54) duplicated block id: 230 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) duplicated block id: 231 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (558:567) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (598:607) duplicated block id: 232 size: 9 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java (135:144) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java (201:210) duplicated block id: 233 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 234 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (500:509) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (598:607) duplicated block id: 235 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (500:509) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (558:567) duplicated block id: 236 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 237 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 238 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) duplicated block id: 239 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) duplicated block id: 240 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 241 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) duplicated block id: 242 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 243 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 244 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (94:104) duplicated block id: 245 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 246 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (131:141) duplicated block id: 247 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/HashAlgorithm.java (35:44) - mantis-network/src/main/java/io/reactivex/mantis/network/push/HashFunctions.java (45:54) duplicated block id: 248 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/LifecycleEventsProto.java (133:143) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/LifecycleEventsProto.java (146:156) duplicated block id: 249 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (105:115) duplicated block id: 250 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) duplicated block id: 251 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (82:92) duplicated block id: 252 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (124:134) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 253 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (50:60) - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (190:200) duplicated block id: 254 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (500:509) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (674:683) duplicated block id: 255 size: 9 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/SseSinkConnectionFunction.java (82:100) - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnectionFunction.java (79:97) duplicated block id: 256 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (85:95) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (48:59) duplicated block id: 257 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (37:47) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (86:96) duplicated block id: 258 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (81:91) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (155:165) duplicated block id: 259 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (500:509) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (636:645) duplicated block id: 260 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (114:124) - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (69:79) duplicated block id: 261 size: 9 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpClientListener.java (93:104) - mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpServerListener.java (61:71) duplicated block id: 262 size: 9 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (636:645) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (712:721) duplicated block id: 263 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (472:479) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (494:501) duplicated block id: 264 size: 8 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (176:183) - mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (93:100) duplicated block id: 265 size: 8 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedDataSourceSink.java (70:79) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedDataSourceSink.java (64:73) duplicated block id: 266 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/MantisServerSentEvent.java (40:47) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 267 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/FilterableMantisStageMetadataWritable.java (36:43) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisStageMetadataWritable.java (58:65) duplicated block id: 268 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/BaseRoute.java (120:127) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java (105:112) duplicated block id: 269 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/Label.java (53:60) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 270 size: 8 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java (97:105) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java (151:159) duplicated block id: 271 size: 8 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/MantisKafkaProducerConfig.java (110:120) - mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumerConfig.java (144:154) duplicated block id: 272 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (453:460) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (494:501) duplicated block id: 273 size: 8 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java (134:141) duplicated block id: 274 size: 8 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (50:59) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (109:118) duplicated block id: 275 size: 8 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/MantisClient.java (243:250) - mantis-client/src/main/java/io/mantisrx/client/MantisClient.java (278:285) duplicated block id: 276 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java (95:104) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java (84:93) duplicated block id: 277 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java (245:253) - mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java (121:129) duplicated block id: 278 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java (85:92) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 279 size: 8 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToScalar.java (129:142) - mantis-runtime/src/main/java/io/mantisrx/runtime/KeyToKey.java (119:132) duplicated block id: 280 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorOnErrorResumeNextViaFunction.java (93:103) - mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorOnErrorResumeNextViaObservable.java (91:101) duplicated block id: 281 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/utils/ConfigUtils.java (150:161) - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java (208:219) duplicated block id: 282 size: 8 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java (94:102) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java (116:124) duplicated block id: 283 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (117:124) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 284 size: 8 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (67:74) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (259:266) duplicated block id: 285 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (88:95) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 286 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java (52:59) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 287 size: 8 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/OperatorResumeOnCompleted.java (66:79) - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/OperatorResumeOnError.java (71:84) duplicated block id: 288 size: 8 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToGroup.java (117:130) - mantis-runtime/src/main/java/io/mantisrx/runtime/KeyToScalar.java (99:112) duplicated block id: 289 size: 8 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (67:74) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (176:183) duplicated block id: 290 size: 8 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/SseSinkConnectionFunction.java (65:72) - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnectionFunction.java (62:69) duplicated block id: 291 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java (108:115) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 292 size: 8 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (160:169) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (243:252) duplicated block id: 293 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobRoute.java (88:97) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java (84:93) duplicated block id: 294 size: 8 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (97:104) duplicated block id: 295 size: 8 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedEventFilter.java (77:87) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedEventFilter.java (72:82) duplicated block id: 296 size: 8 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/SourceSink.java (61:71) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedDataSourceSink.java (75:84) duplicated block id: 297 size: 8 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (123:130) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (176:183) duplicated block id: 298 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/utils/ConfigUtils.java (150:161) - mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/AgentV2Main.java (141:152) duplicated block id: 299 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java (193:200) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 300 size: 8 cleaned lines of code in 2 files: - mantis-common-serde/src/main/java/io/mantisrx/common/JsonSerializer.java (28:36) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java (39:47) duplicated block id: 301 size: 8 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (267:275) - mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (145:153) duplicated block id: 302 size: 8 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (123:130) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (259:266) duplicated block id: 303 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/WorkerPorts.java (86:99) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/WorkerRequest.java (142:155) duplicated block id: 304 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java (89:96) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 305 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/Jar.java (28:36) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (305:313) duplicated block id: 306 size: 8 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/SinkClientImpl.java (229:237) - mantis-client/src/main/java/io/mantisrx/client/SinkClientImpl.java (247:255) duplicated block id: 307 size: 8 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java (87:95) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java (155:163) duplicated block id: 308 size: 8 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/KeyToKey.java (119:132) - mantis-runtime/src/main/java/io/mantisrx/runtime/KeyToScalar.java (99:112) duplicated block id: 309 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java (127:134) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 310 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java (105:117) - mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java (137:149) duplicated block id: 311 size: 8 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToGroup.java (117:130) - mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToScalar.java (129:142) duplicated block id: 312 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IMantisStageMetadata.java (53:96) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisStageMetadata.java (30:44) duplicated block id: 313 size: 8 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/ChoiceOfTwoEventTransmitter.java (102:110) - mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/RoundRobinEventTransmitter.java (83:91) duplicated block id: 314 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobId.java (84:91) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 315 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/LeaderRedirectionFilter.java (73:80) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/LeaderRedirectionFilter.java (102:109) duplicated block id: 316 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (433:440) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java (494:501) duplicated block id: 317 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (158:165) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 318 size: 8 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryCachingImpl.java (144:153) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryStaticImpl.java (109:118) duplicated block id: 319 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (302:310) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (440:449) duplicated block id: 320 size: 8 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToGroup.java (64:78) - mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToKey.java (60:73) duplicated block id: 321 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (442:452) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java (510:519) duplicated block id: 322 size: 8 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java (72:79) - mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java (115:122) duplicated block id: 323 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (2504:2511) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (2559:2566) duplicated block id: 324 size: 7 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (74:80) - mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (85:91) duplicated block id: 325 size: 7 cleaned lines of code in 2 files: - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java (640:647) - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java (664:671) duplicated block id: 326 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (2206:2213) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (2329:2336) duplicated block id: 327 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/NamedJobInfo.java (33:43) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterInfo.java (31:41) duplicated block id: 328 size: 7 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/FixedConnectionSet.java (103:113) - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/DefaultHttpServerProvider.java (127:137) duplicated block id: 329 size: 7 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (110:118) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (161:169) duplicated block id: 330 size: 7 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/FixedConnectionSet.java (103:113) - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/DefaultHttpServerProvider.java (83:93) duplicated block id: 331 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (2206:2213) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (2262:2269) duplicated block id: 332 size: 7 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java (152:161) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java (147:156) duplicated block id: 333 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1150:1156) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1398:1404) duplicated block id: 334 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobDiscoveryRoute.java (218:224) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/LastSubmittedJobIdStreamRoute.java (101:108) duplicated block id: 335 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerResourceStatus.java (50:58) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerUnscheduleable.java (44:52) duplicated block id: 336 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (458:464) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (469:475) duplicated block id: 337 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerLaunchFailed.java (51:59) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerUnscheduleable.java (44:52) duplicated block id: 338 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/ConditionalRetry.java (50:57) - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java (92:99) duplicated block id: 339 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java (455:461) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java (476:482) duplicated block id: 340 size: 7 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/QueryRequestPostProcessor.java (43:51) - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/QueryRequestPreProcessor.java (48:56) duplicated block id: 341 size: 7 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnection.java (96:106) - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/DefaultHttpServerProvider.java (83:93) duplicated block id: 342 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/FilterableMantisStageMetadataWritable.java (36:42) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java (97:103) duplicated block id: 343 size: 7 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/StageWorkersCount.java (55:62) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/TestGetMasterMonitor.java (46:53) duplicated block id: 344 size: 7 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnection.java (96:106) - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/DefaultHttpServerProvider.java (127:137) duplicated block id: 345 size: 7 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java (80:88) - mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/factory/DefaultIcebergWriterFactory.java (35:41) duplicated block id: 346 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisStageMetadataWritable.java (79:89) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisWorkerMetadataWritable.java (98:108) duplicated block id: 347 size: 7 cleaned lines of code in 2 files: - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/QueryRequestPostProcessor.java (40:48) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/QueryRequestPreProcessor.java (41:49) duplicated block id: 348 size: 7 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/QueryRequestPostProcessor.java (43:51) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/QueryRequestPreProcessor.java (41:49) duplicated block id: 349 size: 7 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/SourceSink.java (63:71) - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedDataSourceSink.java (82:90) duplicated block id: 350 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerOnDisabledVM.java (37:45) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerUnscheduleable.java (44:52) duplicated block id: 351 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerLaunchFailed.java (51:59) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerResourceStatus.java (50:58) duplicated block id: 352 size: 7 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java (92:98) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java (126:132) duplicated block id: 353 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerOnDisabledVM.java (37:45) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerResourceStatus.java (50:58) duplicated block id: 354 size: 7 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (51:59) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (244:252) duplicated block id: 355 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (442:451) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java (339:348) duplicated block id: 356 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/ResourceClusterScaleRuleProto.java (89:95) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/ResourceClusterScaleSpec.java (29:35) duplicated block id: 357 size: 7 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java (107:115) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java (170:178) duplicated block id: 358 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (750:756) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (844:850) duplicated block id: 359 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (3046:3053) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (3080:3087) duplicated block id: 360 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerLaunched.java (83:91) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerResourceStatus.java (50:58) duplicated block id: 361 size: 7 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/Parameter.java (38:50) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/MasterDescriptionRoute.java (62:72) duplicated block id: 362 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1325:1335) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1471:1482) duplicated block id: 363 size: 7 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java (192:199) - mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java (346:353) duplicated block id: 364 size: 7 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToScalar.java (65:76) - mantis-runtime/src/main/java/io/mantisrx/runtime/KeyToScalar.java (54:65) duplicated block id: 365 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java (90:96) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java (109:115) duplicated block id: 366 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (514:520) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (533:539) duplicated block id: 367 size: 7 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/QueryRequestPreProcessor.java (48:56) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/QueryRequestPostProcessor.java (40:48) duplicated block id: 368 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java (123:129) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java (138:144) duplicated block id: 369 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/HighAvailabilityServicesUtil.java (66:72) - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master/LocalLeaderFactory.java (51:57) duplicated block id: 370 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobListHelperActor.java (87:93) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobListHelperActor.java (121:127) duplicated block id: 371 size: 7 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/QueryRequestPreProcessor.java (48:56) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/QueryRequestPreProcessor.java (41:49) duplicated block id: 372 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerLaunched.java (83:91) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerUnscheduleable.java (44:52) duplicated block id: 373 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (497:503) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (572:578) duplicated block id: 374 size: 7 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (169:175) - mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (85:91) duplicated block id: 375 size: 7 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/MantisClient.java (277:283) - mantis-client/src/main/java/io/mantisrx/client/MantisClient.java (292:298) duplicated block id: 376 size: 7 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (169:175) - mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (74:80) duplicated block id: 377 size: 7 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (289:295) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java (559:565) duplicated block id: 378 size: 7 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/QueryRefCountMap.java (50:57) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/QueryRefCountMap.java (46:53) duplicated block id: 379 size: 7 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/BufferOnBackPressureOperator.java (60:66) - mantis-common/src/main/java/io/reactivx/mantis/operators/BufferOnBackPressureOperator.java (89:95) duplicated block id: 380 size: 7 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (110:118) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (244:252) duplicated block id: 381 size: 7 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedDataSourceSink.java (82:90) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedDataSourceSink.java (76:84) duplicated block id: 382 size: 7 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/parameter/Parameter.java (38:50) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (67:79) duplicated block id: 383 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerLaunched.java (83:91) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerOnDisabledVM.java (37:45) duplicated block id: 384 size: 7 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java (118:124) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java (191:197) duplicated block id: 385 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerLaunchFailed.java (51:59) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerOnDisabledVM.java (37:45) duplicated block id: 386 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerLaunchFailed.java (51:59) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerLaunched.java (83:91) duplicated block id: 387 size: 7 cleaned lines of code in 2 files: - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java (555:565) - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java (397:407) duplicated block id: 388 size: 7 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnection.java (96:106) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/FixedConnectionSet.java (103:113) duplicated block id: 389 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java (111:121) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java (127:136) duplicated block id: 390 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobDiscoveryStreamRoute.java (57:65) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/LastSubmittedJobIdStreamRoute.java (57:65) duplicated block id: 391 size: 7 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorOnErrorResumeNextViaFunction.java (59:68) - mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorOnErrorResumeNextViaObservable.java (82:91) duplicated block id: 392 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java (348:354) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java (387:393) duplicated block id: 393 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobDiscoveryStreamRoute.java (70:79) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/LastSubmittedJobIdStreamRoute.java (69:78) duplicated block id: 394 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (491:497) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (520:526) duplicated block id: 395 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (288:294) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (305:311) duplicated block id: 396 size: 7 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/BufferOnBackPressureOperator.java (252:260) - mantis-common/src/main/java/io/reactivx/mantis/operators/DropOperator.java (130:138) duplicated block id: 397 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java (97:103) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisStageMetadataWritable.java (58:64) duplicated block id: 398 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (928:934) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1054:1060) duplicated block id: 399 size: 7 cleaned lines of code in 2 files: - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java (103:110) - mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/MantisAgent.java (31:39) duplicated block id: 400 size: 7 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/mantisapi/DefaultMantisApiClient.java (70:76) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/mantisapi/DefaultMantisApiClient.java (100:106) duplicated block id: 401 size: 7 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (51:59) - mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java (161:169) duplicated block id: 402 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java (126:132) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (80:86) duplicated block id: 403 size: 7 cleaned lines of code in 2 files: - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MantisHttpClientImpl.java (55:62) - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MantisHttpClientImpl.java (67:74) duplicated block id: 404 size: 7 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/command/ReadJobFromJar.java (40:49) - mantis-runtime/src/main/java/io/mantisrx/runtime/command/ReadJobFromZip.java (49:58) duplicated block id: 405 size: 7 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/DoOnRequestOperator.java (77:87) - mantis-common/src/main/java/io/reactivx/mantis/operators/OnSubscribeRedo.java (217:227) duplicated block id: 406 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java (266:278) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (271:283) duplicated block id: 407 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (2262:2269) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (2329:2336) duplicated block id: 408 size: 7 cleaned lines of code in 2 files: - mantis-rxcontrol/src/main/java/io/mantisrx/control/clutch/ClutchConfigurator.java (73:79) - mantis-rxcontrol/src/main/java/io/mantisrx/control/clutch/ExperimentalClutchConfigurator.java (42:48) duplicated block id: 409 size: 7 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java (55:62) - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java (95:102) duplicated block id: 410 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobDiscoveryRoute.java (246:253) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java (131:137) duplicated block id: 411 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java (300:305) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (245:250) duplicated block id: 412 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (566:571) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (759:765) duplicated block id: 413 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (152:157) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (177:182) duplicated block id: 414 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (152:157) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (166:171) duplicated block id: 415 size: 6 cleaned lines of code in 2 files: - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java (641:647) - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/scheduling/JobSchedulingTracker.java (111:118) duplicated block id: 416 size: 6 cleaned lines of code in 2 files: - mantis-common/src/jmh/java/io/reactivx/common/compression/CompressionUtilsBenchmark.java (61:70) - mantis-common/src/jmh/java/io/reactivx/common/compression/CompressionUtilsBenchmark.java (86:93) duplicated block id: 417 size: 6 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/MantisClient.java (247:254) - mantis-client/src/main/java/io/mantisrx/client/MantisClient.java (265:272) duplicated block id: 418 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (985:991) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1876:1882) duplicated block id: 419 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1125:1130) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1389:1394) duplicated block id: 420 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (627:634) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (670:677) duplicated block id: 421 size: 6 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java (74:81) - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java (95:101) duplicated block id: 422 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java (83:90) - mantis-remote-observable/src/main/java/io/reactivex/netty/codec/Codecs.java (47:54) duplicated block id: 423 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java (77:84) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java (98:105) duplicated block id: 424 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobDefinitionResolver.java (123:130) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobDefinitionResolver.java (144:151) duplicated block id: 425 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (744:751) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (2242:2249) duplicated block id: 426 size: 6 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java (280:285) - mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java (314:319) duplicated block id: 427 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1236:1242) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1935:1941) duplicated block id: 428 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (985:991) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1935:1941) duplicated block id: 429 size: 6 cleaned lines of code in 2 files: - mantis-source-jobs/mantis-source-job-publish/src/main/java/io/mantisrx/sourcejobs/publish/core/RequestPostProcessor.java (43:49) - mantis-source-jobs/mantis-source-job-publish/src/main/java/io/mantisrx/sourcejobs/publish/core/RequestPreProcessor.java (46:52) duplicated block id: 430 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (985:991) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1071:1077) duplicated block id: 431 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java (568:573) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java (600:605) duplicated block id: 432 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1236:1242) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1876:1882) duplicated block id: 433 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java (229:234) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (232:237) duplicated block id: 434 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1116:1121) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1380:1385) duplicated block id: 435 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/BaseRoute.java (88:93) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java (234:239) duplicated block id: 436 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (1099:1104) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (1171:1178) duplicated block id: 437 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (90:95) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (104:109) duplicated block id: 438 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (324:331) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (617:624) duplicated block id: 439 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (495:502) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (617:624) duplicated block id: 440 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (473:482) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (782:791) duplicated block id: 441 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java (213:218) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java (427:432) duplicated block id: 442 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpClientListener.java (227:234) - mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpServerListener.java (123:131) duplicated block id: 443 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (79:85) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (985:991) duplicated block id: 444 size: 6 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (159:164) - mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (85:90) duplicated block id: 445 size: 6 cleaned lines of code in 2 files: - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java (665:671) - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/scheduling/JobSchedulingTracker.java (111:118) duplicated block id: 446 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (473:482) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (719:728) duplicated block id: 447 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java (37:57) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (28:33) duplicated block id: 448 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1071:1077) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1462:1468) duplicated block id: 449 size: 6 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/MantisClient.java (243:248) - mantis-client/src/main/java/io/mantisrx/client/MantisClient.java (293:298) duplicated block id: 450 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (166:171) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (177:182) duplicated block id: 451 size: 6 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (159:164) - mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (74:79) duplicated block id: 452 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1236:1242) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1316:1322) duplicated block id: 453 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (208:213) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (220:225) duplicated block id: 454 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (391:400) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (93:102) duplicated block id: 455 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java (702:707) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java (717:722) duplicated block id: 456 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java (66:73) - mantis-remote-observable/src/main/java/io/reactivex/netty/codec/Codecs.java (64:71) duplicated block id: 457 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (306:311) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterGateway.java (76:81) duplicated block id: 458 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1080:1090) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1245:1254) duplicated block id: 459 size: 6 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java (280:285) - mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java (361:366) duplicated block id: 460 size: 6 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java (119:124) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java (151:156) duplicated block id: 461 size: 6 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/MrePublishClientInitializer.java (78:84) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/providers/MrePublishClientInitializerProvider.java (60:65) duplicated block id: 462 size: 6 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/netty/codec/Codecs.java (47:54) - mantis-remote-observable/src/main/java/io/reactivex/netty/codec/Codecs.java (64:71) duplicated block id: 463 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1316:1322) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1935:1941) duplicated block id: 464 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java (262:269) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java (274:279) duplicated block id: 465 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (438:443) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (533:538) duplicated block id: 466 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (304:310) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java (339:346) duplicated block id: 467 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1876:1882) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1935:1941) duplicated block id: 468 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (985:991) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1316:1322) duplicated block id: 469 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1316:1322) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1876:1882) duplicated block id: 470 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (432:439) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (807:814) duplicated block id: 471 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (495:502) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (679:686) duplicated block id: 472 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (432:439) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (744:751) duplicated block id: 473 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (495:502) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (744:751) duplicated block id: 474 size: 6 cleaned lines of code in 2 files: - mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/Hardware.java (190:195) - mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/Hardware.java (236:241) duplicated block id: 475 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (736:741) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (787:792) duplicated block id: 476 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (985:991) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1236:1242) duplicated block id: 477 size: 6 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServers.java (47:52) - mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServers.java (62:67) duplicated block id: 478 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (93:102) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (393:402) duplicated block id: 479 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobDiscoveryRoute.java (179:184) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/LastSubmittedJobIdStreamRoute.java (104:109) duplicated block id: 480 size: 6 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/HttpSourceServerHandler.java (116:122) - mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/HttpSourceServerHandler.java (141:147) duplicated block id: 481 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (432:439) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (679:686) duplicated block id: 482 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (495:502) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (807:814) duplicated block id: 483 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java (568:573) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java (584:589) duplicated block id: 484 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (324:331) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (432:439) duplicated block id: 485 size: 6 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java (314:319) - mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java (361:366) duplicated block id: 486 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (79:85) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1462:1468) duplicated block id: 487 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (289:294) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterGateway.java (76:81) duplicated block id: 488 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/IKeyValueStore.java (157:163) - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/IKeyValueStore.java (169:175) duplicated block id: 489 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobListHelperActor.java (121:126) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (1188:1193) duplicated block id: 490 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1071:1077) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1316:1322) duplicated block id: 491 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (807:814) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (2242:2249) duplicated block id: 492 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorOnErrorResumeNextViaFunction.java (85:93) - mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorOnErrorResumeNextViaObservable.java (62:70) duplicated block id: 493 size: 6 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedDataSourceSink.java (85:90) - mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java (91:96) duplicated block id: 494 size: 6 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedDataSourceSink.java (85:90) - mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java (56:61) duplicated block id: 495 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (324:331) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (495:502) duplicated block id: 496 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java (111:116) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (91:96) duplicated block id: 497 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java (170:179) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java (245:254) duplicated block id: 498 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpClientListener.java (122:129) - mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpServerListener.java (79:86) duplicated block id: 499 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (79:85) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1236:1242) duplicated block id: 500 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java (697:706) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (410:418) duplicated block id: 501 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java (281:288) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java (298:305) duplicated block id: 502 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/network/Endpoint.java (133:138) - mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java (97:102) duplicated block id: 503 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java (594:600) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobRoute.java (369:376) duplicated block id: 504 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (324:331) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (2242:2249) duplicated block id: 505 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (744:751) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (807:814) duplicated block id: 506 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1071:1077) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1935:1941) duplicated block id: 507 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (206:211) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (217:222) duplicated block id: 508 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/BufferOnBackPressureOperator.java (124:130) - mantis-common/src/main/java/io/reactivx/mantis/operators/BufferOnBackPressureOperator.java (146:152) duplicated block id: 509 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java (265:271) - mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java (300:306) duplicated block id: 510 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobListHelperActor.java (87:92) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobListHelperActor.java (164:169) duplicated block id: 511 size: 6 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (159:164) - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (169:174) duplicated block id: 512 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1071:1077) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1876:1882) duplicated block id: 513 size: 6 cleaned lines of code in 2 files: - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/utils/ErrorComputer.java (75:81) - mantis-rxcontrol/src/main/java/io/mantisrx/control/controllers/ErrorComputer.java (80:86) duplicated block id: 514 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (985:991) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1462:1468) duplicated block id: 515 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (432:439) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (2242:2249) duplicated block id: 516 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/StatusEventBrokerActor.java (75:85) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1885:1894) duplicated block id: 517 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/WorkerTopologyInfo.java (50:55) - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/WorkerTopologyInfo.java (61:66) duplicated block id: 518 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (432:439) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (617:624) duplicated block id: 519 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (617:624) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (2242:2249) duplicated block id: 520 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java (584:589) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java (600:605) duplicated block id: 521 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java (66:73) - mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java (83:90) duplicated block id: 522 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java (253:262) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (258:267) duplicated block id: 523 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (415:421) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (607:613) duplicated block id: 524 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobListHelperActor.java (121:126) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobListHelperActor.java (164:169) duplicated block id: 525 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1071:1077) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1236:1242) duplicated block id: 526 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java (307:314) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (262:271) duplicated block id: 527 size: 6 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/executor/StageExecutors.java (225:231) - mantis-runtime/src/main/java/io/mantisrx/runtime/executor/StageExecutors.java (296:301) duplicated block id: 528 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java (24:29) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java (37:57) duplicated block id: 529 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (582:591) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (719:728) duplicated block id: 530 size: 6 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/stage/TaggingStage.java (51:56) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/AbstractAckableTaggingStage.java (42:47) duplicated block id: 531 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (582:591) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (782:791) duplicated block id: 532 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (79:85) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1316:1322) duplicated block id: 533 size: 6 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java (56:61) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedDataSourceSink.java (79:84) duplicated block id: 534 size: 6 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnection.java (53:59) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnection.java (71:77) duplicated block id: 535 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (136:141) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (177:182) duplicated block id: 536 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (495:502) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (2242:2249) duplicated block id: 537 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java (138:143) - mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java (238:243) duplicated block id: 538 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (136:141) - mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java (166:171) duplicated block id: 539 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (79:85) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1071:1077) duplicated block id: 540 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java (300:305) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java (243:248) duplicated block id: 541 size: 6 cleaned lines of code in 2 files: - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/stage/TaggingStage.java (79:84) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/AbstractAckableTaggingStage.java (55:60) duplicated block id: 542 size: 6 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/SourceSink.java (66:71) - mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java (56:61) duplicated block id: 543 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterGateway.java (67:72) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterGateway.java (75:80) duplicated block id: 544 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java (103:108) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java (111:116) duplicated block id: 545 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/Jar.java (51:60) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterConfig.java (63:72) duplicated block id: 546 size: 6 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/SourceSink.java (66:71) - mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java (91:96) duplicated block id: 547 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java (304:310) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java (510:516) duplicated block id: 548 size: 6 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/HttpClientFactories.java (82:91) - mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/HttpClientFactories.java (132:141) duplicated block id: 549 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (264:269) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (288:293) duplicated block id: 550 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (264:269) - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java (305:310) duplicated block id: 551 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorOnErrorResumeNextViaFunction.java (68:74) - mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorOnErrorResumeNextViaObservable.java (70:76) duplicated block id: 552 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterConfig.java (63:72) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (327:336) duplicated block id: 553 size: 6 cleaned lines of code in 2 files: - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java (275:283) - mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/MantisAgent.java (51:59) duplicated block id: 554 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (679:686) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (2242:2249) duplicated block id: 555 size: 6 cleaned lines of code in 2 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java (91:96) - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedDataSourceSink.java (79:84) duplicated block id: 556 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/config/StaticPropertiesConfigurationFactory.java (37:42) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/StaticPropertiesConfigurationFactory.java (65:70) duplicated block id: 557 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (432:439) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (495:502) duplicated block id: 558 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (72:81) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (293:303) duplicated block id: 559 size: 6 cleaned lines of code in 2 files: - mantis-client/src/main/java/io/mantisrx/client/SinkConnectionsStatus.java (33:42) - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/WorkerConnectionsStatus.java (31:40) duplicated block id: 560 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (617:624) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (807:814) duplicated block id: 561 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (324:331) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (679:686) duplicated block id: 562 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (79:85) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1935:1941) duplicated block id: 563 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (679:686) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (744:751) duplicated block id: 564 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (617:624) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (744:751) duplicated block id: 565 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobListHelperActor.java (164:169) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (1188:1193) duplicated block id: 566 size: 6 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointingDisabledTrigger.java (44:51) - mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CountingCheckpointTrigger.java (67:74) duplicated block id: 567 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (324:331) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (744:751) duplicated block id: 568 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (617:624) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (679:686) duplicated block id: 569 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (324:331) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (807:814) duplicated block id: 570 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1236:1242) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1462:1468) duplicated block id: 571 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1462:1468) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1935:1941) duplicated block id: 572 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (473:482) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (582:591) duplicated block id: 573 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/http/api/CompactJobInfo.java (80:89) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (274:283) duplicated block id: 574 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (391:400) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (393:402) duplicated block id: 575 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobListHelperActor.java (87:92) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (1188:1193) duplicated block id: 576 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (79:85) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1876:1882) duplicated block id: 577 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1462:1468) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (1876:1882) duplicated block id: 578 size: 6 cleaned lines of code in 2 files: - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java (55:61) - mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java (74:81) duplicated block id: 579 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java (269:278) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/http/api/CompactJobInfo.java (80:89) duplicated block id: 580 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (679:686) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java (807:814) duplicated block id: 581 size: 6 cleaned lines of code in 2 files: - mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpClientListener.java (60:67) - mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpServerListener.java (41:48)