duplicated block id: 1 size: 40 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/IdentifierRules.java (127:168) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/IdentifierRules.java (86:127) duplicated block id: 2 size: 36 cleaned lines of code in 14 files: - connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/ConfigUtil.java (30:69) - connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java (29:68) - connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java (74:115) - connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java (66:105) - connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java (30:69) - connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/config/ConfigUtil.java (35:74) - connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/util/ConfigUtil.java (30:69) - connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/config/ConnectorConfig.java (49:88) - connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/config/SourceConnectorConfig.java (45:84) - connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/config/SinkConnectorConfig.java (42:81) - connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java (241:280) - connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveConfig.java (112:151) - connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConfig.java (118:157) - rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java (23:61) duplicated block id: 3 size: 34 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/table/TableId.java (103:138) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java (102:137) duplicated block id: 4 size: 31 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/ColumnDefinition.java (57:89) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java (58:90) duplicated block id: 5 size: 30 cleaned lines of code in 2 files: - connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java (111:142) - connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java (104:136) duplicated block id: 6 size: 22 cleaned lines of code in 2 files: - connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqAdminUtil.java (197:220) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java (244:267) duplicated block id: 7 size: 21 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/RecordValidator.java (47:76) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java (29:58) duplicated block id: 8 size: 21 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/ColumnDefinition.java (268:290) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java (269:291) duplicated block id: 9 size: 20 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java (171:193) - connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java (165:187) duplicated block id: 10 size: 18 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java (98:117) - connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java (98:117) duplicated block id: 11 size: 18 cleaned lines of code in 2 files: - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/FileAndPropertyUtil.java (83:104) - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils/FileAndPropertyUtil.java (41:62) duplicated block id: 12 size: 17 cleaned lines of code in 2 files: - connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnector.java (137:157) - connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java (145:165) duplicated block id: 13 size: 16 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java (31:48) - connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java (31:48) duplicated block id: 14 size: 16 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java (126:143) - connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java (126:143) duplicated block id: 15 size: 16 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/metadata/FieldsMetadata.java (45:62) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java (45:62) duplicated block id: 16 size: 15 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ExpressionBuilder.java (35:59) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java (26:43) duplicated block id: 17 size: 15 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/metadata/SinkRecordField.java (63:80) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java (63:80) duplicated block id: 18 size: 14 cleaned lines of code in 2 files: - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ServerUtil.java (39:55) - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils/ServerUtil.java (39:55) duplicated block id: 19 size: 13 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/metadata/FieldsMetadata.java (279:293) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java (276:290) duplicated block id: 20 size: 13 cleaned lines of code in 2 files: - connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java (53:67) - connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/connector/MqttSinkTask.java (46:60) duplicated block id: 21 size: 12 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java (200:214) - connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java (194:208) duplicated block id: 22 size: 12 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/JdbcDriverInfo.java (122:135) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/JdbcDriverInfo.java (121:134) duplicated block id: 23 size: 12 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/FloatDeserializer.java (23:37) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/FloatDeserializer.java (23:37) duplicated block id: 24 size: 12 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/IntegerDeserializer.java (23:37) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/IntegerDeserializer.java (23:37) duplicated block id: 25 size: 12 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/LongDeserializer.java (23:37) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/LongDeserializer.java (23:37) duplicated block id: 26 size: 12 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/ShortDeserializer.java (24:38) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/ShortDeserializer.java (24:38) duplicated block id: 27 size: 12 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/table/TableId.java (68:81) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java (67:80) duplicated block id: 28 size: 12 cleaned lines of code in 2 files: - connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/SchemaManger.java (27:40) - connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSourceTask.java (138:151) duplicated block id: 29 size: 12 cleaned lines of code in 2 files: - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ServerUtil.java (63:78) - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils/ServerUtil.java (63:78) duplicated block id: 30 size: 12 cleaned lines of code in 3 files: - transforms/src/main/java/org/apache/rocketmq/connect/transforms/ChangeCase.java (94:107) - transforms/src/main/java/org/apache/rocketmq/connect/transforms/PatternRename.java (112:125) - transforms/src/main/java/org/apache/rocketmq/connect/transforms/ExtractNestedField.java (85:98) duplicated block id: 31 size: 12 cleaned lines of code in 3 files: - transforms/src/main/java/org/apache/rocketmq/connect/transforms/ChangeCase.java (115:128) - transforms/src/main/java/org/apache/rocketmq/connect/transforms/PatternRename.java (133:146) - transforms/src/main/java/org/apache/rocketmq/connect/transforms/ExtractNestedField.java (106:119) duplicated block id: 32 size: 11 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ExpressionBuilder.java (577:589) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java (313:325) duplicated block id: 33 size: 11 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/JdbcDriverInfo.java (40:52) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/JdbcDriverInfo.java (39:51) duplicated block id: 34 size: 11 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/DoubleDeserializer.java (24:37) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/DoubleDeserializer.java (24:37) duplicated block id: 35 size: 11 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/RecordValidator.java (33:45) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java (86:98) duplicated block id: 36 size: 11 cleaned lines of code in 3 files: - connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java (61:74) - connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java (61:74) - connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java (83:96) duplicated block id: 37 size: 11 cleaned lines of code in 2 files: - connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/KafkaConnectAdaptorSink.java (42:54) - connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/KafkaConnectAdaptorSource.java (43:55) duplicated block id: 38 size: 10 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/JdbcDriverInfo.java (108:119) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/JdbcDriverInfo.java (107:118) duplicated block id: 39 size: 10 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/table/TableId.java (89:100) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java (88:99) duplicated block id: 40 size: 9 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java (156:166) - connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java (150:160) duplicated block id: 41 size: 9 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java (221:231) - connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java (215:225) duplicated block id: 42 size: 9 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java (239:249) - connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java (233:243) duplicated block id: 43 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ExpressionBuilder.java (277:287) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java (139:149) duplicated block id: 44 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ExpressionBuilder.java (299:309) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java (155:165) duplicated block id: 45 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ExpressionBuilder.java (486:496) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java (243:253) duplicated block id: 46 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ExpressionBuilder.java (523:533) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java (259:269) duplicated block id: 47 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ExpressionBuilder.java (560:570) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java (296:306) duplicated block id: 48 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/TableType.java (53:63) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/TableType.java (53:63) duplicated block id: 49 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/StringDeserializer.java (38:48) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/StringDeserializer.java (38:48) duplicated block id: 50 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/RecordValidator.java (78:88) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java (60:70) duplicated block id: 51 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/RecordValidator.java (90:100) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java (72:82) duplicated block id: 52 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/ColumnId.java (42:52) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnId.java (41:51) duplicated block id: 53 size: 9 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/ColumnId.java (89:99) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnId.java (88:98) duplicated block id: 54 size: 9 cleaned lines of code in 3 files: - connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java (49:59) - connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java (49:59) - connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java (67:77) duplicated block id: 55 size: 9 cleaned lines of code in 2 files: - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/TransferUtils.java (60:71) - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils/FileAndPropertyUtil.java (64:75) duplicated block id: 56 size: 9 cleaned lines of code in 3 files: - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/QueryConnectorStatusSubCommand.java (59:69) - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/QueryConnectorConfigSubCommand.java (59:69) - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/StopConnectorSubCommand.java (59:69) duplicated block id: 57 size: 8 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-fc/src/main/java/org/apache/rocketmq/connect/fc/sink/FcSinkConnector.java (67:76) - connectors/aliyun/rocketmq-connect-fc/src/main/java/org/apache/rocketmq/connect/fc/sink/FcSinkTask.java (97:106) duplicated block id: 58 size: 8 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkTask.java (88:97) - connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java (74:83) duplicated block id: 59 size: 8 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/IdentifierRules.java (176:185) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/IdentifierRules.java (129:138) duplicated block id: 60 size: 8 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/ColumnId.java (72:81) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnId.java (71:80) duplicated block id: 61 size: 8 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/table/TableId.java (32:41) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java (31:40) duplicated block id: 62 size: 8 cleaned lines of code in 2 files: - connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTask.java (106:115) - connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java (127:136) duplicated block id: 63 size: 8 cleaned lines of code in 2 files: - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalStateManagementServiceImpl.java (77:86) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/rocketmq/RocketMqStateManagementServiceImpl.java (51:60) duplicated block id: 64 size: 8 cleaned lines of code in 2 files: - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalConfigManagementServiceImpl.java (79:88) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/rocketmq/RocketMqConfigManagementServiceImpl.java (53:62) duplicated block id: 65 size: 8 cleaned lines of code in 4 files: - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/GetClusterInfoSubCommand.java (53:62) - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/GetAllocatedInfoCommand.java (53:62) - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/GetConfigInfoSubCommand.java (53:62) - rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/StopAllSubCommand.java (53:62) duplicated block id: 66 size: 7 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ExpressionBuilder.java (133:141) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java (63:71) duplicated block id: 67 size: 7 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ExpressionBuilder.java (360:368) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java (187:195) duplicated block id: 68 size: 7 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/IdentifierRules.java (75:83) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/IdentifierRules.java (45:53) duplicated block id: 69 size: 7 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/StringSerializer.java (29:37) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/StringSerializer.java (29:37) duplicated block id: 70 size: 7 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/ColumnDefinition.java (328:336) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java (329:337) duplicated block id: 71 size: 7 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector/DorisSinkTask.java (78:86) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkTask.java (87:95) duplicated block id: 72 size: 6 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java (50:57) - connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java (50:57) duplicated block id: 73 size: 6 cleaned lines of code in 2 files: - connectors/aliyun/rocketmq-connect-rocketmq/src/main/java/org/apache/rocketmq/connect/rocketmq/RocketMQSourceConnector.java (102:109) - connectors/aliyun/rocketmq-connect-rocketmq/src/main/java/org/apache/rocketmq/connect/rocketmq/RocketMQSourceTask.java (72:79) duplicated block id: 74 size: 6 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/BytesUtil.java (22:29) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/BytesUtil.java (21:28) duplicated block id: 75 size: 6 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/QuoteMethod.java (23:30) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/QuoteMethod.java (28:35) duplicated block id: 76 size: 6 cleaned lines of code in 2 files: - connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector/DorisSinkConnector.java (61:68) - connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConnector.java (65:72) duplicated block id: 77 size: 6 cleaned lines of code in 2 files: - connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java (100:108) - connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java (93:101) duplicated block id: 78 size: 6 cleaned lines of code in 2 files: - connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils/ReplicatorUtils.java (96:103) - rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java (313:320)