duplicated block id: 1 size: 63 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (378:467) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (473:562) duplicated block id: 2 size: 60 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (284:367) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (378:461) duplicated block id: 3 size: 60 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (284:367) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (473:556) duplicated block id: 4 size: 39 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (278:331) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (335:388) duplicated block id: 5 size: 39 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (220:273) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (278:331) duplicated block id: 6 size: 39 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (220:273) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (335:388) duplicated block id: 7 size: 36 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala (65:105) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala (64:104) duplicated block id: 8 size: 29 cleaned lines of code in 2 files: - csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala (230:258) - csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala (262:290) duplicated block id: 9 size: 27 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala (33:63) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala (32:62) duplicated block id: 10 size: 25 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (90:114) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (117:141) duplicated block id: 11 size: 22 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (269:290) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (294:315) duplicated block id: 12 size: 22 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (269:290) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (317:338) duplicated block id: 13 size: 22 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (294:315) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (317:338) duplicated block id: 14 size: 21 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (112:132) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (138:158) duplicated block id: 15 size: 20 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (88:107) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (139:158) duplicated block id: 16 size: 20 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (88:107) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (113:132) duplicated block id: 17 size: 18 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/NotificationTarget.scala (28:57) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/NotificationTarget.scala (26:54) duplicated block id: 18 size: 16 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmNotificationModels.scala (111:132) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/NotificationTarget.scala (33:54) duplicated block id: 19 size: 16 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmNotificationModels.scala (111:132) - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/NotificationTarget.scala (36:57) duplicated block id: 20 size: 16 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala (107:127) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala (230:250) duplicated block id: 21 size: 16 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmSender.scala (42:64) - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmSender.scala (37:59) duplicated block id: 22 size: 16 cleaned lines of code in 2 files: - pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/PravegaSettings.scala (399:420) - pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/PravegaSettings.scala (520:541) duplicated block id: 23 size: 15 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (645:659) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (715:729) duplicated block id: 24 size: 15 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (568:582) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (679:693) duplicated block id: 25 size: 14 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (663:676) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (734:747) duplicated block id: 26 size: 14 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmJsonSupport.scala (38:58) - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmJsonSupport.scala (32:52) duplicated block id: 27 size: 13 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (57:69) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (102:114) duplicated block id: 28 size: 13 cleaned lines of code in 2 files: - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala (149:163) - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala (157:171) duplicated block id: 29 size: 13 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpOperations.scala (41:60) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpsOperations.scala (36:55) duplicated block id: 30 size: 13 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (57:69) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (129:141) duplicated block id: 31 size: 13 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (344:358) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (687:701) duplicated block id: 32 size: 13 cleaned lines of code in 2 files: - csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala (340:352) - csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala (356:368) duplicated block id: 33 size: 13 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala (306:325) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala (361:380) duplicated block id: 34 size: 13 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (452:464) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (738:750) duplicated block id: 35 size: 12 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala (592:603) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala (608:619) duplicated block id: 36 size: 12 cleaned lines of code in 2 files: - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApiV5.scala (62:77) - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApiV7.scala (54:69) duplicated block id: 37 size: 12 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/Bucket.scala (101:112) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/Bucket.scala (116:127) duplicated block id: 38 size: 12 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (312:323) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (356:367) duplicated block id: 39 size: 11 cleaned lines of code in 2 files: - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala (23:43) - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala (23:43) duplicated block id: 40 size: 11 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (178:188) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (213:223) duplicated block id: 41 size: 11 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala (212:225) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala (361:375) duplicated block id: 42 size: 11 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala (176:189) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/settings.scala (101:114) duplicated block id: 43 size: 11 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryArrowStorage.scala (46:57) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorage.scala (46:57) duplicated block id: 44 size: 11 cleaned lines of code in 2 files: - google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/ForwardProxyPoolSettings.scala (52:62) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (1094:1104) duplicated block id: 45 size: 11 cleaned lines of code in 2 files: - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala (112:125) - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala (125:138) duplicated block id: 46 size: 11 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (415:425) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (452:462) duplicated block id: 47 size: 11 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (415:425) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (738:748) duplicated block id: 48 size: 11 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (375:388) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (722:735) duplicated block id: 49 size: 11 cleaned lines of code in 2 files: - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala (169:180) - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala (202:213) duplicated block id: 50 size: 11 cleaned lines of code in 2 files: - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala (116:128) - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala (148:160) duplicated block id: 51 size: 11 cleaned lines of code in 2 files: - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala (70:80) - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala (73:83) duplicated block id: 52 size: 11 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (18:28) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (117:127) duplicated block id: 53 size: 11 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (18:28) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (90:100) duplicated block id: 54 size: 11 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (90:100) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala (38:48) duplicated block id: 55 size: 11 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (18:28) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala (38:48) duplicated block id: 56 size: 11 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala (212:225) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala (306:320) duplicated block id: 57 size: 11 cleaned lines of code in 2 files: - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala (87:98) - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala (90:101) duplicated block id: 58 size: 11 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (1136:1151) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (1227:1242) duplicated block id: 59 size: 11 cleaned lines of code in 2 files: - orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/javadsl/OrientDbSource.scala (48:62) - orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/scaladsl/OrientDbSource.scala (38:52) duplicated block id: 60 size: 11 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/ObjectAccessControls.scala (117:127) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala (38:48) duplicated block id: 61 size: 11 cleaned lines of code in 2 files: - pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableReadFlow.scala (110:128) - pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableWriteFlow.scala (117:136) duplicated block id: 62 size: 10 cleaned lines of code in 2 files: - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala (83:94) - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala (151:162) duplicated block id: 63 size: 10 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala (388:397) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala (459:468) duplicated block id: 64 size: 10 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (237:246) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (715:724) duplicated block id: 65 size: 10 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageSettings.scala (160:169) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageSettings.scala (173:182) duplicated block id: 66 size: 10 cleaned lines of code in 2 files: - text/src/main/scala/org/apache/pekko/stream/connectors/text/impl/CharsetLogic.scala (118:133) - text/src/main/scala/org/apache/pekko/stream/connectors/text/impl/CharsetLogic.scala (183:198) duplicated block id: 67 size: 10 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (415:424) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (667:676) duplicated block id: 68 size: 10 cleaned lines of code in 2 files: - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpFlowStageLogic.scala (42:55) - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpReplyToSinkStage.scala (58:72) duplicated block id: 69 size: 10 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryArrowStorage.scala (35:44) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorage.scala (35:44) duplicated block id: 70 size: 10 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (251:264) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (618:631) duplicated block id: 71 size: 10 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (452:461) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (667:676) duplicated block id: 72 size: 10 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (969:979) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (1143:1153) duplicated block id: 73 size: 10 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (237:246) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (645:654) duplicated block id: 74 size: 10 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (236:249) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (603:616) duplicated block id: 75 size: 9 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsBrowseSettings.scala (93:102) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala (172:182) duplicated block id: 76 size: 9 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmJsonSupport.scala (192:202) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitJsonSupport.scala (113:122) duplicated block id: 77 size: 9 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (186:194) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (216:224) duplicated block id: 78 size: 9 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (360:368) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (703:711) duplicated block id: 79 size: 9 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmJsonSupport.scala (205:213) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitJsonSupport.scala (128:136) duplicated block id: 80 size: 9 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala (18:37) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala (18:37) duplicated block id: 81 size: 9 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (277:285) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (312:320) duplicated block id: 82 size: 9 cleaned lines of code in 2 files: - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (100:108) - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (153:161) duplicated block id: 83 size: 9 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (277:285) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (356:364) duplicated block id: 84 size: 9 cleaned lines of code in 2 files: - google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/ForwardProxyHttpsContext.scala (32:41) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/ForwardProxyHttpsContext.scala (49:58) duplicated block id: 85 size: 9 cleaned lines of code in 2 files: - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchWriteSettings.scala (78:87) - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchWriteSettings.scala (26:35) duplicated block id: 86 size: 9 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (584:592) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (713:721) duplicated block id: 87 size: 9 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala (18:37) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala (18:37) duplicated block id: 88 size: 9 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmJsonSupport.scala (62:72) - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmJsonSupport.scala (112:122) duplicated block id: 89 size: 8 cleaned lines of code in 2 files: - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala (83:92) - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala (119:128) duplicated block id: 90 size: 8 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (533:541) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (658:666) duplicated block id: 91 size: 8 cleaned lines of code in 2 files: - pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaFlow.scala (92:107) - pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableWriteFlow.scala (122:135) duplicated block id: 92 size: 8 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (283:293) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (218:230) duplicated block id: 93 size: 8 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala (115:123) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala (209:217) duplicated block id: 94 size: 8 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (266:276) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (633:643) duplicated block id: 95 size: 8 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (334:341) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (400:408) duplicated block id: 96 size: 8 cleaned lines of code in 2 files: - google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala (69:80) - google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala (91:103) duplicated block id: 97 size: 8 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (519:526) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (662:669) duplicated block id: 98 size: 8 cleaned lines of code in 2 files: - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (177:184) - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (196:203) duplicated block id: 99 size: 8 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (153:160) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (161:168) duplicated block id: 100 size: 8 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (144:151) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (152:159) duplicated block id: 101 size: 8 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (84:91) - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (64:71) duplicated block id: 102 size: 8 cleaned lines of code in 2 files: - google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala (150:159) - google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala (188:197) duplicated block id: 103 size: 8 cleaned lines of code in 2 files: - sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala (154:162) - sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala (207:215) duplicated block id: 104 size: 8 cleaned lines of code in 2 files: - influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/javadsl/InfluxDbSource.scala (37:48) - influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/scaladsl/InfluxDbSource.scala (37:48) duplicated block id: 105 size: 8 cleaned lines of code in 2 files: - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/impl/ReferenceFlowStage.scala (31:44) - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/impl/ReferenceWithResourceFlowStage.scala (33:46) duplicated block id: 106 size: 8 cleaned lines of code in 2 files: - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrFlow.scala (54:61) - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrFlow.scala (73:80) duplicated block id: 107 size: 8 cleaned lines of code in 2 files: - pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaFlow.scala (92:107) - pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableReadFlow.scala (114:127) duplicated block id: 108 size: 8 cleaned lines of code in 2 files: - sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala (138:145) - sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala (191:198) duplicated block id: 109 size: 8 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (377:387) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (277:288) duplicated block id: 110 size: 8 cleaned lines of code in 2 files: - xml/src/main/scala/org/apache/pekko/stream/connectors/xml/impl/Subslice.scala (80:92) - xml/src/main/scala/org/apache/pekko/stream/connectors/xml/impl/Subtree.scala (114:126) duplicated block id: 111 size: 8 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (67:74) - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (73:80) duplicated block id: 112 size: 8 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (207:214) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (210:217) duplicated block id: 113 size: 8 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmJsonSupport.scala (162:169) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitJsonSupport.scala (75:82) duplicated block id: 114 size: 8 cleaned lines of code in 2 files: - google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/QueryJsonProtocol.scala (254:262) - google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableDataJsonProtocol.scala (58:66) duplicated block id: 115 size: 8 cleaned lines of code in 2 files: - slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala (214:221) - slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala (248:255) duplicated block id: 116 size: 8 cleaned lines of code in 2 files: - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrFlow.scala (59:66) - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrFlow.scala (80:87) duplicated block id: 117 size: 8 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (197:205) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (305:313) duplicated block id: 118 size: 8 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (472:482) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (334:345) duplicated block id: 119 size: 8 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala (107:115) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala (106:114) duplicated block id: 120 size: 8 cleaned lines of code in 2 files: - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchSourceSettings.scala (29:37) - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchSourceSettings.scala (28:35) duplicated block id: 121 size: 7 cleaned lines of code in 2 files: - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (69:75) - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (122:128) duplicated block id: 122 size: 7 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/javadsl/GoogleFcm.scala (30:36) - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/javadsl/GoogleFcm.scala (28:34) duplicated block id: 123 size: 7 cleaned lines of code in 2 files: - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala (49:56) - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala (81:88) duplicated block id: 124 size: 7 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmFlows.scala (41:49) - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmFlows.scala (37:45) duplicated block id: 125 size: 7 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (208:214) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (153:159) duplicated block id: 126 size: 7 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala (292:301) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (826:835) duplicated block id: 127 size: 7 cleaned lines of code in 2 files: - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (84:90) - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (137:143) duplicated block id: 128 size: 7 cleaned lines of code in 2 files: - google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala (18:32) - google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala (18:32) duplicated block id: 129 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (473:482) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (220:230) duplicated block id: 130 size: 7 cleaned lines of code in 2 files: - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala (75:81) - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala (89:95) duplicated block id: 131 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (473:482) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (278:288) duplicated block id: 132 size: 7 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/SplitAfterSize.scala (51:59) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/SplitAfterSizeWithContext.scala (48:56) duplicated block id: 133 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala (105:112) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala (199:206) duplicated block id: 134 size: 7 cleaned lines of code in 2 files: - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApiV5.scala (40:46) - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApiV7.scala (37:43) duplicated block id: 135 size: 7 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (250:256) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (271:277) duplicated block id: 136 size: 7 cleaned lines of code in 2 files: - google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala (18:32) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala (18:33) duplicated block id: 137 size: 7 cleaned lines of code in 2 files: - google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala (18:32) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala (18:33) duplicated block id: 138 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpGraphStageLogic.scala (62:70) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala (238:246) duplicated block id: 139 size: 7 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (643:649) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (661:667) duplicated block id: 140 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (284:293) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (278:288) duplicated block id: 141 size: 7 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (221:227) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (162:168) duplicated block id: 142 size: 7 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/settings.scala (435:441) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/settings.scala (479:485) duplicated block id: 143 size: 7 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (145:151) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (211:217) duplicated block id: 144 size: 7 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (154:160) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (221:227) duplicated block id: 145 size: 7 cleaned lines of code in 2 files: - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/impl/ReferenceFlowStage.scala (66:75) - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/impl/ReferenceWithResourceFlowStage.scala (68:77) duplicated block id: 146 size: 7 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala (292:301) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (920:929) duplicated block id: 147 size: 7 cleaned lines of code in 2 files: - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrFlow.scala (110:116) - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrFlow.scala (129:135) duplicated block id: 148 size: 7 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (67:73) - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (50:56) duplicated block id: 149 size: 7 cleaned lines of code in 2 files: - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala (93:103) - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala (85:94) duplicated block id: 150 size: 7 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (63:69) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (105:111) duplicated block id: 151 size: 7 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (50:56) - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (73:79) duplicated block id: 152 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (378:387) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (335:345) duplicated block id: 153 size: 7 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (145:151) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (208:214) duplicated block id: 154 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala (125:131) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala (219:225) duplicated block id: 155 size: 7 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (153:159) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (211:217) duplicated block id: 156 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (378:387) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (220:230) duplicated block id: 157 size: 7 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (643:652) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (726:735) duplicated block id: 158 size: 7 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/Mqtt.scala (39:45) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/Mqtt.scala (60:66) duplicated block id: 159 size: 7 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (457:463) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (532:538) duplicated block id: 160 size: 7 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (826:835) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (920:929) duplicated block id: 161 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpGraphStageLogic.scala (62:70) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala (115:123) duplicated block id: 162 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala (284:293) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala (335:345) duplicated block id: 163 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala (18:23) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala (18:23) duplicated block id: 164 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (124:129) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (330:335) duplicated block id: 165 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (357:362) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (740:745) duplicated block id: 166 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala (18:23) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala (18:23) duplicated block id: 167 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (257:262) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (651:656) duplicated block id: 168 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (517:522) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (550:555) duplicated block id: 169 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (629:634) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (800:805) duplicated block id: 170 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (620:628) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (635:643) duplicated block id: 171 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (124:129) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (307:312) duplicated block id: 172 size: 6 cleaned lines of code in 2 files: - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpReplyToSinkStage.scala (48:55) - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala (225:232) duplicated block id: 173 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala (967:972) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala (1022:1027) duplicated block id: 174 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (114:119) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (271:276) duplicated block id: 175 size: 6 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmNotificationModels.scala (156:162) - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/FcmNotification.scala (30:36) duplicated block id: 176 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala (18:23) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala (18:23) duplicated block id: 177 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala (18:23) - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala (18:23) duplicated block id: 178 size: 6 cleaned lines of code in 2 files: - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/impl/ReferenceFlowStage.scala (49:59) - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/impl/ReferenceWithResourceFlowStage.scala (51:61) duplicated block id: 179 size: 6 cleaned lines of code in 2 files: - mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoSink.scala (22:33) - mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/scaladsl/MongoSink.scala (21:33) duplicated block id: 180 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (655:661) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (976:982) duplicated block id: 181 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala (18:23) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala (18:23) duplicated block id: 182 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (89:94) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (319:324) duplicated block id: 183 size: 6 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (202:212) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (219:229) duplicated block id: 184 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (150:155) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (307:312) duplicated block id: 185 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (78:83) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (257:262) duplicated block id: 186 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala (18:23) - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala (18:23) duplicated block id: 187 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (89:94) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (296:301) duplicated block id: 188 size: 6 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (523:528) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (693:698) duplicated block id: 189 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (140:145) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (271:276) duplicated block id: 190 size: 6 cleaned lines of code in 2 files: - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala (318:323) - google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala (394:399) duplicated block id: 191 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (1130:1135) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (1180:1185) duplicated block id: 192 size: 6 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (382:387) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (393:398) duplicated block id: 193 size: 6 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (202:212) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (236:246) duplicated block id: 194 size: 6 cleaned lines of code in 2 files: - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchWriteSettings.scala (94:99) - elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchWriteSettings.scala (42:47) duplicated block id: 195 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (238:246) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (268:276) duplicated block id: 196 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (99:104) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (307:312) duplicated block id: 197 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (238:246) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (253:261) duplicated block id: 198 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (278:283) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (454:459) duplicated block id: 199 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala (18:23) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala (18:23) duplicated block id: 200 size: 6 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (174:179) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (523:528) duplicated block id: 201 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (65:70) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (243:248) duplicated block id: 202 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala (18:23) - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala (18:23) duplicated block id: 203 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (89:94) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (271:276) duplicated block id: 204 size: 6 cleaned lines of code in 2 files: - cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala (59:64) - cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala (78:83) duplicated block id: 205 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (278:283) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (417:422) duplicated block id: 206 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala (18:23) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala (18:23) duplicated block id: 207 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (791:806) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (420:436) duplicated block id: 208 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (238:246) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (635:643) duplicated block id: 209 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (278:283) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (669:674) duplicated block id: 210 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala (169:175) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala (162:168) duplicated block id: 211 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (99:104) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (330:335) duplicated block id: 212 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (238:246) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (620:628) duplicated block id: 213 size: 6 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (219:229) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (236:246) duplicated block id: 214 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (357:362) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (417:422) duplicated block id: 215 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (257:262) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (721:726) duplicated block id: 216 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala (18:23) - google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala (18:23) duplicated block id: 217 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala (18:23) - google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala (18:23) duplicated block id: 218 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (357:362) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (669:674) duplicated block id: 219 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (114:119) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (319:324) duplicated block id: 220 size: 6 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (345:350) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (523:528) duplicated block id: 221 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala (140:146) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala (136:142) duplicated block id: 222 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (1153:1158) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (1244:1249) duplicated block id: 223 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (114:119) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (296:301) duplicated block id: 224 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (150:155) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (282:287) duplicated block id: 225 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (413:418) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (468:473) duplicated block id: 226 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (357:362) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (454:459) duplicated block id: 227 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala (18:23) - google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala (18:23) duplicated block id: 228 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (268:276) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (605:613) duplicated block id: 229 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (140:145) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (296:301) duplicated block id: 230 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala (177:183) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala (170:176) duplicated block id: 231 size: 6 cleaned lines of code in 2 files: - google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala (18:23) - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala (18:23) duplicated block id: 232 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (140:145) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (319:324) duplicated block id: 233 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (268:276) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (620:628) duplicated block id: 234 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala (18:23) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala (18:23) duplicated block id: 235 size: 6 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (345:350) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (693:698) duplicated block id: 236 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (253:261) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (605:613) duplicated block id: 237 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (253:261) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (268:276) duplicated block id: 238 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala (18:23) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala (18:23) duplicated block id: 239 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (99:104) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (282:287) duplicated block id: 240 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (253:261) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (635:643) duplicated block id: 241 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (465:470) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (540:545) duplicated block id: 242 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (278:283) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (740:745) duplicated block id: 243 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala (18:23) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala (18:23) duplicated block id: 244 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (709:714) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (796:801) duplicated block id: 245 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (313:318) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (740:745) duplicated block id: 246 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala (18:23) - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala (18:23) duplicated block id: 247 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala (18:23) - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala (18:23) duplicated block id: 248 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (313:318) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (417:422) duplicated block id: 249 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala (186:192) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala (178:184) duplicated block id: 250 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (313:318) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (669:674) duplicated block id: 251 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala (1203:1208) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala (1218:1223) duplicated block id: 252 size: 6 cleaned lines of code in 2 files: - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpAsyncFlowStageLogic.scala (114:121) - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpFlowStageLogic.scala (69:76) duplicated block id: 253 size: 6 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/model.scala (55:60) - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/model.scala (64:69) duplicated block id: 254 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala (196:201) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala (187:192) duplicated block id: 255 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (626:632) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (709:715) duplicated block id: 256 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (150:155) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (330:335) duplicated block id: 257 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (605:613) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (620:628) duplicated block id: 258 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala (18:23) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala (18:23) duplicated block id: 259 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcPublisher.scala (18:23) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala (18:23) duplicated block id: 260 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (605:613) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala (635:643) duplicated block id: 261 size: 6 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (174:179) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (182:187) duplicated block id: 262 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (313:318) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (454:459) duplicated block id: 263 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (1612:1629) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (1076:1093) duplicated block id: 264 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryExt.scala (18:23) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcSubscriber.scala (18:23) duplicated block id: 265 size: 6 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (174:179) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (345:350) duplicated block id: 266 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (510:515) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (582:587) duplicated block id: 267 size: 6 cleaned lines of code in 2 files: - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettingExt.scala (18:23) - reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala (18:23) duplicated block id: 268 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala (124:129) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (282:287) duplicated block id: 269 size: 6 cleaned lines of code in 2 files: - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala (149:154) - google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala (145:150) duplicated block id: 270 size: 6 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (892:897) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (903:908) duplicated block id: 271 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala (64:69) - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GooglePubSub.scala (65:70) duplicated block id: 272 size: 6 cleaned lines of code in 2 files: - google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala (18:23) - google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleExt.scala (18:23) duplicated block id: 273 size: 6 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (174:179) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (693:698) duplicated block id: 274 size: 6 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (556:561) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (567:572) duplicated block id: 275 size: 6 cleaned lines of code in 2 files: - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrFlow.scala (121:126) - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrFlow.scala (141:146) duplicated block id: 276 size: 6 cleaned lines of code in 2 files: - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/javadsl/HdfsFlow.scala (121:126) - hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala (129:134) duplicated block id: 277 size: 6 cleaned lines of code in 2 files: - google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmJsonSupport.scala (170:175) - huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitJsonSupport.scala (84:89)