duplicated block id: 1 size: 260 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConnector.scala (39:422) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConnector.scala (40:423) duplicated block id: 2 size: 125 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsProducerStage.scala (60:267) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala (59:266) duplicated block id: 3 size: 87 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (344:512) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (345:513) duplicated block id: 4 size: 83 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (862:1022) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (863:1023) duplicated block id: 5 size: 83 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (522:683) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (523:684) duplicated block id: 6 size: 82 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (173:335) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (174:336) duplicated block id: 7 size: 80 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (692:853) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (693:854) duplicated block id: 8 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: 9 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: 10 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: 11 size: 49 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (29:164) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (30:165) duplicated block id: 12 size: 45 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageReader.scala (31:98) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageReader.scala (31:98) duplicated block id: 13 size: 44 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Headers.scala (19:160) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/Headers.scala (20:161) duplicated block id: 14 size: 43 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsConsumerSettings.scala (116:161) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala (116:161) duplicated block id: 15 size: 41 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SourceStageLogic.scala (34:95) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/SourceStageLogic.scala (34:95) duplicated block id: 16 size: 41 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SourceStageLogic.scala (99:165) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/SourceStageLogic.scala (99:165) duplicated block id: 17 size: 39 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Credentials.scala (18:77) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/Credentials.scala (18:77) duplicated block id: 18 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: 19 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: 20 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: 21 size: 37 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsProducer.scala (28:105) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/JmsProducer.scala (28:105) duplicated block id: 22 size: 36 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/model.scala (23:69) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala (25:71) duplicated block id: 23 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: 24 size: 35 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala (48:94) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsTxSourceStage.scala (47:93) duplicated block id: 25 size: 35 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsBrowseStage.scala (28:74) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsBrowseStage.scala (28:74) duplicated block id: 26 size: 33 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsConsumerSettings.scala (172:206) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala (172:206) duplicated block id: 27 size: 33 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsExceptions.scala (25:67) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsExceptions.scala (25:67) duplicated block id: 28 size: 33 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/scaladsl/MqttFlow.scala (29:89) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala (34:94) duplicated block id: 29 size: 32 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/settings.scala (29:141) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/settings.scala (35:147) duplicated block id: 30 size: 30 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/SendRetrySettings.scala (27:76) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/SendRetrySettings.scala (27:76) duplicated block id: 31 size: 30 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/AcknowledgeMode.scala (22:64) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/AcknowledgeMode.scala (22:64) duplicated block id: 32 size: 30 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/Sessions.scala (94:135) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/Sessions.scala (95:136) duplicated block id: 33 size: 29 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala (50:86) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsAckSourceStage.scala (50:86) duplicated block id: 34 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: 35 size: 28 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsConsumer.scala (35:100) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/JmsConsumer.scala (34:99) duplicated block id: 36 size: 28 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsProducerSettings.scala (89:119) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsProducerSettings.scala (89:119) duplicated block id: 37 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: 38 size: 26 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsConsumerSettings.scala (46:114) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala (46:114) duplicated block id: 39 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: 40 size: 24 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/ConnectionRetrySettings.scala (60:91) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/ConnectionRetrySettings.scala (60:91) duplicated block id: 41 size: 23 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageProducer.scala (24:57) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducer.scala (24:57) duplicated block id: 42 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: 43 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: 44 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: 45 size: 21 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (226:258) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (369:400) duplicated block id: 46 size: 21 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttFlow.scala (46:84) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala (45:83) duplicated block id: 47 size: 21 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsBrowseSettings.scala (59:82) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsBrowseSettings.scala (59:82) duplicated block id: 48 size: 21 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsConnectorState.scala (23:65) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/JmsConnectorState.scala (23:65) duplicated block id: 49 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: 50 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: 51 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: 52 size: 20 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/ConnectionRetrySettings.scala (94:144) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/ConnectionRetrySettings.scala (94:144) duplicated block id: 53 size: 19 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsProducerSettings.scala (130:149) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsProducerSettings.scala (130:149) duplicated block id: 54 size: 19 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Destinations.scala (23:74) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/Destinations.scala (22:73) duplicated block id: 55 size: 18 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/SendRetrySettings.scala (79:129) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/SendRetrySettings.scala (79:129) duplicated block id: 56 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: 57 size: 18 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsBrowseSettings.scala (93:111) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsBrowseSettings.scala (93:111) duplicated block id: 58 size: 17 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SoftReferenceCache.scala (25:49) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/SoftReferenceCache.scala (25:49) duplicated block id: 59 size: 17 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageProducer.scala (60:82) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducer.scala (60:82) duplicated block id: 60 size: 16 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttSource.scala (29:60) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala (31:62) duplicated block id: 61 size: 16 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsProducerStage.scala (270:299) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala (269:298) duplicated block id: 62 size: 16 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConsumerStage.scala (53:74) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConsumerStage.scala (53:74) duplicated block id: 63 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: 64 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: 65 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: 66 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: 67 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: 68 size: 15 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (139:163) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (186:209) duplicated block id: 69 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: 70 size: 15 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsProducerSettings.scala (41:87) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsProducerSettings.scala (41:87) duplicated block id: 71 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: 72 size: 14 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsConsumer.scala (109:129) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/JmsConsumer.scala (108:128) duplicated block id: 73 size: 14 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageProducer.scala (87:100) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducer.scala (87:100) duplicated block id: 74 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: 75 size: 14 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageProducer.scala (123:143) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducer.scala (123:143) duplicated block id: 76 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: 77 size: 14 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageProducer.scala (105:118) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducer.scala (105:118) duplicated block id: 78 size: 13 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpOperations.scala (45:64) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpsOperations.scala (50:69) duplicated block id: 79 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: 80 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: 81 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: 82 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: 83 size: 13 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/Sessions.scala (61:84) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/Sessions.scala (62:85) duplicated block id: 84 size: 13 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConsumerStage.scala (30:51) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConsumerStage.scala (30:51) duplicated block id: 85 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: 86 size: 13 cleaned lines of code in 2 files: - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala (156:170) - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala (162:176) duplicated block id: 87 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: 88 size: 12 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/scaladsl/MqttSource.scala (28:55) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala (31:58) duplicated block id: 89 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: 90 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: 91 size: 12 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsProducerStage.scala (36:57) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala (36:57) duplicated block id: 92 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: 93 size: 12 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsConsumerSettings.scala (28:39) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala (28:39) duplicated block id: 94 size: 12 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala (593:604) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala (609:620) duplicated block id: 95 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: 96 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 (1103:1113) duplicated block id: 97 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: 98 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: 99 size: 11 cleaned lines of code in 2 files: - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala (79:89) - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala (82:92) duplicated block id: 100 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: 101 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: 102 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 (40:50) duplicated block id: 103 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: 104 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: 105 size: 11 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (267:282) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (433:449) duplicated block id: 106 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: 107 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: 108 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: 109 size: 11 cleaned lines of code in 2 files: - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala (121:134) - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala (134:147) duplicated block id: 110 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: 111 size: 11 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (34:47) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (35:48) duplicated block id: 112 size: 11 cleaned lines of code in 2 files: - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala (96:107) - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala (99:110) duplicated block id: 113 size: 11 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala (33:48) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsAckSourceStage.scala (33:48) duplicated block id: 114 size: 11 cleaned lines of code in 2 files: - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala (32:52) - mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala (32:52) duplicated block id: 115 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 (40:50) duplicated block id: 116 size: 11 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (1145:1160) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (1235:1250) duplicated block id: 117 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: 118 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: 119 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 (40:50) duplicated block id: 120 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: 121 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: 122 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: 123 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: 124 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: 125 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: 126 size: 10 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/package.scala (25:35) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/package.scala (25:35) duplicated block id: 127 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: 128 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: 129 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: 130 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: 131 size: 10 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (973:983) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (1147:1157) duplicated block id: 132 size: 10 cleaned lines of code in 2 files: - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/dynamodb/DynamoDBITTest.scala (43:53) - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/kinesis/KinesisITTest.scala (37:47) duplicated block id: 133 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: 134 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: 135 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: 136 size: 10 cleaned lines of code in 2 files: - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (72:81) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (77:86) duplicated block id: 137 size: 9 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsBrowseSettings.scala (93:102) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsConsumerSettings.scala (172:182) duplicated block id: 138 size: 9 cleaned lines of code in 2 files: - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (102:110) - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (156:164) duplicated block id: 139 size: 9 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsBrowseSettings.scala (93:102) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala (172:182) duplicated block id: 140 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: 141 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: 142 size: 9 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsConsumerSettings.scala (172:182) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsBrowseSettings.scala (93:102) duplicated block id: 143 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: 144 size: 9 cleaned lines of code in 2 files: - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/dynamodb/DynamoDBITTest.scala (44:53) - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/s3/S3ITTest.scala (40:49) duplicated block id: 145 size: 9 cleaned lines of code in 2 files: - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/kinesis/KinesisITTest.scala (38:47) - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/s3/S3ITTest.scala (40:49) duplicated block id: 146 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: 147 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: 148 size: 9 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (192:203) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (241:252) duplicated block id: 149 size: 9 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttMessageWithAck.scala (30:56) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala (29:55) duplicated block id: 150 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: 151 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: 152 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: 153 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: 154 size: 9 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (126:137) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (173:184) duplicated block id: 155 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: 156 size: 9 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/InternalConnectionState.scala (35:43) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/InternalConnectionState.scala (35:43) duplicated block id: 157 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: 158 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: 159 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: 160 size: 9 cleaned lines of code in 2 files: - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (51:59) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (77:85) duplicated block id: 161 size: 9 cleaned lines of code in 2 files: - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (72:80) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (51:59) duplicated block id: 162 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: 163 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: 164 size: 8 cleaned lines of code in 2 files: - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrFlow.scala (60:67) - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrFlow.scala (81:88) duplicated block id: 165 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: 166 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: 167 size: 8 cleaned lines of code in 2 files: - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (181:188) - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (200:207) duplicated block id: 168 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: 169 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: 170 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: 171 size: 8 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (521:528) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (557:564) duplicated block id: 172 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: 173 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 (152:161) - google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala (190:199) duplicated block id: 174 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: 175 size: 8 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (175:182) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (222:229) duplicated block id: 176 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: 177 size: 8 cleaned lines of code in 2 files: - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrFlow.scala (55:62) - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrFlow.scala (74:81) duplicated block id: 178 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: 179 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: 180 size: 8 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsBrowseSettings.scala (35:57) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsBrowseSettings.scala (35:57) duplicated block id: 181 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: 182 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 (253:261) - google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableDataJsonProtocol.scala (58:66) duplicated block id: 183 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: 184 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: 185 size: 8 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsSettings.scala (24:31) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsSettings.scala (23:30) duplicated block id: 186 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: 187 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: 188 size: 8 cleaned lines of code in 2 files: - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (90:97) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (68:75) duplicated block id: 189 size: 8 cleaned lines of code in 2 files: - jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConnectorState.java (16:23) - jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl/JmsConnectorState.java (16:23) duplicated block id: 190 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: 191 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: 192 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: 193 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: 194 size: 8 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala (34:45) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsTxSourceStage.scala (34:45) duplicated block id: 195 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: 196 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: 197 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: 198 size: 8 cleaned lines of code in 2 files: - slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala (212:219) - slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala (246:253) duplicated block id: 199 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: 200 size: 7 cleaned lines of code in 2 files: - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrFlow.scala (111:117) - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/scaladsl/SolrFlow.scala (130:136) duplicated block id: 201 size: 7 cleaned lines of code in 2 files: - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (71:77) - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (125:131) duplicated block id: 202 size: 7 cleaned lines of code in 2 files: - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (86:92) - couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala (140:146) duplicated block id: 203 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: 204 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: 205 size: 7 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsProducerSettings.scala (28:34) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsProducerSettings.scala (28:34) duplicated block id: 206 size: 7 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (84:90) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (90:96) duplicated block id: 207 size: 7 cleaned lines of code in 2 files: - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala (76:82) - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala (90:96) duplicated block id: 208 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: 209 size: 7 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala (112:119) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala (225:232) duplicated block id: 210 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: 211 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: 212 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: 213 size: 7 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (64:70) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (68:74) duplicated block id: 214 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: 215 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: 216 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: 217 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: 218 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: 219 size: 7 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConnector.scala (239:245) - kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSchedulerSourceStage.scala (118:124) duplicated block id: 220 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: 221 size: 7 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/GraphStageCompanion.scala (23:33) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/GraphStageCompanion.scala (23:33) duplicated block id: 222 size: 7 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (84:90) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (68:74) duplicated block id: 223 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: 224 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: 225 size: 7 cleaned lines of code in 2 files: - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala (94:104) - amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala (85:94) duplicated block id: 226 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: 227 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: 228 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: 229 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: 230 size: 7 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttFlow.scala (29:44) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala (28:43) duplicated block id: 231 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: 232 size: 7 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (93:102) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (99:108) duplicated block id: 233 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: 234 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: 235 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: 236 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: 237 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: 238 size: 7 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConnector.scala (238:244) - kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSchedulerSourceStage.scala (118:124) duplicated block id: 239 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: 240 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: 241 size: 7 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsProducer.scala (101:112) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducer.scala (101:112) duplicated block id: 242 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: 243 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: 244 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: 245 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: 246 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: 247 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: 248 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: 249 size: 7 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (64:70) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (90:96) duplicated block id: 250 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: 251 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: 252 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsProducerStage.scala (81:90) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SourceStageLogic.scala (59:68) duplicated block id: 253 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: 254 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (664:670) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (985:991) 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 (257:262) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (651:656) 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 (124:129) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (307:312) duplicated block id: 257 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: 258 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (344:349) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (523:528) duplicated block id: 259 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: 260 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: 261 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: 262 size: 6 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStageWithAck.scala (85:92) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala (91:99) duplicated block id: 263 size: 6 cleaned lines of code in 2 files: - couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl/CouchbaseFlow.scala (248:253) - couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl/CouchbaseFlow.scala (261:266) duplicated block id: 264 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: 265 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (344:349) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (692:697) duplicated block id: 266 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (692:697) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (174:179) duplicated block id: 267 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: 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 (257:262) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala (721:726) duplicated block id: 269 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (173:178) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (693:698) duplicated block id: 270 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: 271 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (173:178) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (344:349) duplicated block id: 272 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (891:896) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (903:908) duplicated block id: 273 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (414:419) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (469:474) duplicated block id: 274 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: 275 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: 276 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (555:560) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (567:572) duplicated block id: 277 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: 278 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (344:349) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (174:179) duplicated block id: 279 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: 280 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: 281 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: 282 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (344:349) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (693:698) duplicated block id: 283 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: 284 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (1134:1139) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (1184:1189) duplicated block id: 285 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: 286 size: 6 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/javadsl/MqttSink.scala (28:41) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala (31:44) duplicated block id: 287 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: 288 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: 289 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: 290 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: 291 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: 292 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (344:349) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (522:527) duplicated block id: 293 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: 294 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: 295 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (173:178) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (523:528) duplicated block id: 296 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: 297 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: 298 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (173:178) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (522:527) duplicated block id: 299 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: 300 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConsumer.scala (60:70) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumer.scala (60:70) duplicated block id: 301 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: 302 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: 303 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SourceStageLogic.scala (59:68) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala (80:89) duplicated block id: 304 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: 305 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: 306 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/Sessions.scala (86:92) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/Sessions.scala (87:93) duplicated block id: 307 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsProducer.scala (114:121) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducer.scala (114:121) duplicated block id: 308 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: 309 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: 310 size: 6 cleaned lines of code in 2 files: - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/dynamodb/DynamoDBITTest.scala (47:53) - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/sqs/SQSITTest.scala (45:51) duplicated block id: 311 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: 312 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: 313 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (522:527) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (692:697) duplicated block id: 314 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: 315 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: 316 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: 317 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: 318 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: 319 size: 6 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala (58:65) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala (63:70) duplicated block id: 320 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (1162:1167) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala (1252:1257) duplicated block id: 321 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: 322 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: 323 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: 324 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: 325 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: 326 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: 327 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (692:697) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (345:350) duplicated block id: 328 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (692:697) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (523:528) duplicated block id: 329 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: 330 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: 331 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: 332 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: 333 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) duplicated block id: 334 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (902:907) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (892:897) duplicated block id: 335 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: 336 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsProducerStage.scala (81:90) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/SourceStageLogic.scala (59:68) duplicated block id: 337 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (522:527) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (174:179) duplicated block id: 338 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: 339 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: 340 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: 341 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: 342 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: 343 size: 6 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/model.scala (55:60) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala (66:71) duplicated block id: 344 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: 345 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (522:527) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (693:698) duplicated block id: 346 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: 347 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: 348 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: 349 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: 350 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (566:571) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (556:561) duplicated block id: 351 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: 352 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: 353 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: 354 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: 355 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (555:560) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (566:571) duplicated block id: 356 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: 357 size: 6 cleaned lines of code in 2 files: - mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/model.scala (64:69) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala (57:62) duplicated block id: 358 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (891:896) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (902:907) duplicated block id: 359 size: 6 cleaned lines of code in 2 files: - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala (971:976) - mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala (1026:1031) duplicated block id: 360 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: 361 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: 362 size: 6 cleaned lines of code in 2 files: - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/s3/S3ITTest.scala (43:49) - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/sqs/SQSITTest.scala (45:51) duplicated block id: 363 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: 364 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: 365 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: 366 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: 367 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: 368 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (522:527) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (345:350) duplicated block id: 369 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: 370 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: 371 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/ConnectionRetrySettings.scala (28:33) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/ConnectionRetrySettings.scala (28:33) duplicated block id: 372 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: 373 size: 6 cleaned lines of code in 2 files: - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/kinesis/KinesisITTest.scala (41:47) - aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/sqs/SQSITTest.scala (45:51) duplicated block id: 374 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: 375 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: 376 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: 377 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (381:386) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (392:397) duplicated block id: 378 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (392:397) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (382:387) duplicated block id: 379 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: 380 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (381:386) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (393:398) duplicated block id: 381 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: 382 size: 6 cleaned lines of code in 2 files: - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala (80:89) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/SourceStageLogic.scala (59:68) duplicated block id: 383 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (173:178) - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (692:697) duplicated block id: 384 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: 385 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: 386 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsProducer.scala (89:99) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducer.scala (89:99) duplicated block id: 387 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: 388 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: 389 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: 390 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: 391 size: 6 cleaned lines of code in 2 files: - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrFlow.scala (124:129) - solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrFlow.scala (144:149) duplicated block id: 392 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: 393 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (1616:1633) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (1076:1093) duplicated block id: 394 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: 395 size: 6 cleaned lines of code in 2 files: - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala (57:62) - mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala (66:71) duplicated block id: 396 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: 397 size: 6 cleaned lines of code in 2 files: - jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala (173:178) - jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala (345:350) duplicated block id: 398 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: 399 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: 400 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: 401 size: 6 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (209:219) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (226:236) duplicated block id: 402 size: 6 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (209:219) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (243:253) duplicated block id: 403 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: 404 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: 405 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: 406 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: 407 size: 6 cleaned lines of code in 2 files: - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala (793:808) - s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala (420:436) duplicated block id: 408 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: 409 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: 410 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 (236:243) duplicated block id: 411 size: 6 cleaned lines of code in 2 files: - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (226:236) - ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala (243:253)