duplicated block id: 1 size: 21 cleaned lines of code in 2 files: - mantis-rxcontrol/src/main/java/io/mantisrx/control/IController.java (45:70) - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/Controller.java (38:63) duplicated block id: 2 size: 20 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java (51:73) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java (45:67) duplicated block id: 3 size: 16 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/ZookeeperLeaderElector.java (63:83) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/LeaderElector.java (68:88) duplicated block id: 4 size: 16 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerStatus.java (57:82) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerHeartbeat.java (57:81) duplicated block id: 5 size: 15 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/ZookeeperLeaderElector.java (122:141) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/LeaderElector.java (120:139) duplicated block id: 6 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 (314:332) - mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java (264:282) duplicated block id: 7 size: 14 cleaned lines of code in 2 files: - mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java (223:240) - mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java (210:227) duplicated block id: 8 size: 14 cleaned lines of code in 2 files: - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedDataSourceSink.java (52:67) - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedDataSourceSink.java (58:73) duplicated block id: 9 size: 14 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/netty/codec/Codecs.java (60:78) - mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java (79:97) duplicated block id: 10 size: 14 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (39:54) - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java (35:50) duplicated block id: 11 size: 14 cleaned lines of code in 4 files: - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageOut.java (26:43) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/SourceOut.java (26:43) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageIn.java (26:43) - mantis-runtime/src/main/java/io/mantisrx/runtime/markers/NetworkMerge.java (26:43) duplicated block id: 12 size: 13 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/ZookeeperLeaderElector.java (103:120) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/LeaderElector.java (101:118) duplicated block id: 13 size: 12 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java (268:282) - mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java (218:232) duplicated block id: 14 size: 11 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/netty/codec/Codecs.java (44:58) - mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java (63:77) duplicated block id: 15 size: 10 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/WorkerHost.java (40:51) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (40:51) duplicated block id: 16 size: 10 cleaned lines of code in 3 files: - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/AbstractAckableTaggingStage.java (133:146) - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/stage/TaggingStage.java (136:149) - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/core/TaggedData.java (61:74) duplicated block id: 17 size: 10 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/netty/codec/Codecs.java (29:42) - mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java (33:46) duplicated block id: 18 size: 10 cleaned lines of code in 2 files: - mantis-remote-observable/src/main/java/io/reactivex/netty/codec/Codecs.java (88:100) - mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java (107:119) duplicated block id: 19 size: 9 cleaned lines of code in 3 files: - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java (208:220) - mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/utils/ConfigUtils.java (150:162) - mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/AgentV2Main.java (141:153) duplicated block id: 20 size: 9 cleaned lines of code in 2 files: - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/MQL.java (87:98) - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/core/MQL.java (87:98) duplicated block id: 21 size: 9 cleaned lines of code in 2 files: - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/MQL.java (100:111) - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/core/MQL.java (100:111) duplicated block id: 22 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java (113:122) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/InMemoryStore.java (49:58) duplicated block id: 23 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java (125:134) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/InMemoryStore.java (61:70) duplicated block id: 24 size: 8 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java (137:146) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/InMemoryStore.java (73:82) duplicated block id: 25 size: 8 cleaned lines of code in 3 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java (125:134) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (79:88) - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java (91:100) duplicated block id: 26 size: 8 cleaned lines of code in 2 files: - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedEventFilter.java (73:83) - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedEventFilter.java (78:88) duplicated block id: 27 size: 7 cleaned lines of code in 2 files: - mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java (189:198) - mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/AgentV2Main.java (119:128) duplicated block id: 28 size: 7 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java (345:353) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java (42:50) duplicated block id: 29 size: 7 cleaned lines of code in 3 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java (84:92) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java (95:103) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobRoute.java (88:96) duplicated block id: 30 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/BaseRoute.java (105:113) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/BaseRoute.java (120:128) duplicated block id: 31 size: 7 cleaned lines of code in 3 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java (110:118) - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (90:98) - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java (102:110) duplicated block id: 32 size: 7 cleaned lines of code in 2 files: - mantis-rxcontrol/src/main/java/io/mantisrx/control/controllers/Derivative.java (27:37) - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/utils/Derivative.java (30:40) duplicated block id: 33 size: 7 cleaned lines of code in 2 files: - mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MetricsClientImpl.java (124:132) - mantis-client/src/main/java/io/mantisrx/client/SinkClientImpl.java (140:148) duplicated block id: 34 size: 7 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (60:68) - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java (72:80) duplicated block id: 35 size: 6 cleaned lines of code in 2 files: - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java (149:156) - mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/InMemoryStore.java (85:92) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - mantis-rxcontrol/src/main/java/io/mantisrx/control/controllers/ErrorComputer.java (80:87) - mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/utils/ErrorComputer.java (75:82) duplicated block id: 37 size: 6 cleaned lines of code in 2 files: - mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/MQLQueryManager.java (57:64) - mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/core/MQLQueryManager.java (57:64) duplicated block id: 38 size: 6 cleaned lines of code in 2 files: - mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (70:77) - mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java (82:89)