duplicated block id: 1 size: 25 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java (51:83) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java (47:79) duplicated block id: 2 size: 22 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java (59:82) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (57:80) duplicated block id: 3 size: 21 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java (89:114) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java (69:94) duplicated block id: 4 size: 21 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java (88:117) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java (88:117) duplicated block id: 5 size: 18 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java (194:221) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowSerializer.java (68:95) duplicated block id: 6 size: 16 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java (122:138) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java (82:98) duplicated block id: 7 size: 16 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (209:224) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (415:430) duplicated block id: 8 size: 15 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (191:205) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (210:224) duplicated block id: 9 size: 15 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java (142:158) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java (100:116) duplicated block id: 10 size: 15 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (191:205) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (416:430) duplicated block id: 11 size: 13 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java (167:182) - flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java (218:233) duplicated block id: 12 size: 13 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (225:237) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (186:198) duplicated block id: 13 size: 12 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java (94:105) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java (106:117) duplicated block id: 14 size: 12 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (194:208) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (164:178) duplicated block id: 15 size: 12 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (162:176) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (164:178) duplicated block id: 16 size: 12 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (162:177) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (154:169) duplicated block id: 17 size: 12 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (162:176) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (194:208) duplicated block id: 18 size: 12 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (194:205) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (187:198) duplicated block id: 19 size: 12 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (194:205) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (226:237) duplicated block id: 20 size: 12 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java (52:63) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java (79:90) duplicated block id: 21 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java (77:90) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java (74:87) duplicated block id: 22 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java (89:103) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java (65:79) duplicated block id: 23 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java (52:62) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyWriter.java (55:65) duplicated block id: 24 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java (107:120) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java (65:79) duplicated block id: 25 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java (148:158) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java (94:104) duplicated block id: 26 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java (84:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java (49:61) duplicated block id: 27 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java (572:588) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java (409:425) duplicated block id: 28 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (124:139) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (117:132) duplicated block id: 29 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java (96:110) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java (120:134) duplicated block id: 30 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java (120:134) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java (96:110) duplicated block id: 31 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (162:175) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (156:169) duplicated block id: 32 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (194:207) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (156:169) duplicated block id: 33 size: 10 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (135:144) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (154:163) duplicated block id: 34 size: 10 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (194:203) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (196:205) duplicated block id: 35 size: 10 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java (213:225) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java (572:584) duplicated block id: 36 size: 10 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (103:114) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (96:107) duplicated block id: 37 size: 10 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java (213:225) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java (409:421) duplicated block id: 38 size: 10 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (226:235) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (196:205) duplicated block id: 39 size: 10 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (196:205) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (187:196) duplicated block id: 40 size: 10 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (211:220) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (203:212) duplicated block id: 41 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java (30:40) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresSchema.java (27:37) duplicated block id: 42 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (124:137) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (123:136) duplicated block id: 43 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java (29:39) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresSchema.java (27:37) duplicated block id: 44 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java (388:397) - flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java (412:421) duplicated block id: 45 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java (88:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java (124:132) duplicated block id: 46 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java (29:39) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java (30:40) duplicated block id: 47 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java (110:126) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java (145:161) duplicated block id: 48 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (119:128) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (106:115) duplicated block id: 49 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresSchema.java (27:37) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerSchema.java (27:37) duplicated block id: 50 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java (88:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (81:89) duplicated block id: 51 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java (30:40) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerSchema.java (27:37) duplicated block id: 52 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (249:257) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (526:534) duplicated block id: 53 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (123:136) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (117:130) duplicated block id: 54 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java (29:39) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerSchema.java (27:37) duplicated block id: 55 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java (145:155) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (129:139) duplicated block id: 56 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (90:97) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (83:90) duplicated block id: 57 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java (98:105) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java (141:148) duplicated block id: 58 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java (113:126) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecord.java (45:58) duplicated block id: 59 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java (121:131) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java (121:131) duplicated block id: 60 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (125:137) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (123:138) duplicated block id: 61 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumDataChange.java (92:101) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java (98:107) duplicated block id: 62 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java (66:73) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java (42:49) duplicated block id: 63 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java (33:46) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecord.java (45:58) duplicated block id: 64 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java (65:72) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java (53:60) duplicated block id: 65 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java (49:56) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (47:54) duplicated block id: 66 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumDataChange.java (73:82) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java (81:89) duplicated block id: 67 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java (33:46) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java (148:161) duplicated block id: 68 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java (85:92) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java (78:85) duplicated block id: 69 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (123:138) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (124:136) duplicated block id: 70 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java (113:126) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java (33:46) duplicated block id: 71 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (123:138) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (118:130) duplicated block id: 72 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java (148:161) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecord.java (45:58) duplicated block id: 73 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java (309:317) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java (176:184) duplicated block id: 74 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java (189:196) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java (133:140) duplicated block id: 75 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java (65:72) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java (57:64) duplicated block id: 76 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java (205:213) - flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java (249:257) duplicated block id: 77 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java (151:161) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyWriter.java (130:140) duplicated block id: 78 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/util/FastDateUtil.java (30:37) - flink-doris-connector/src/main/java/org/apache/doris/flink/util/FastDateUtil.java (52:59) duplicated block id: 79 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java (428:435) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DorisTableConfig.java (102:109) duplicated block id: 80 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (130:139) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (123:132) duplicated block id: 81 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (184:190) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (213:219) duplicated block id: 82 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/util/FastDateUtil.java (40:46) - flink-doris-connector/src/main/java/org/apache/doris/flink/util/FastDateUtil.java (61:67) duplicated block id: 83 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (90:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (85:91) duplicated block id: 84 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java (163:169) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java (110:116) duplicated block id: 85 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (90:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (84:90) duplicated block id: 86 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (100:106) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (163:169) duplicated block id: 87 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java (334:346) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java (200:212) duplicated block id: 88 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (124:133) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (130:139) duplicated block id: 89 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (84:90) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (83:89) duplicated block id: 90 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (130:139) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (117:126) duplicated block id: 91 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (84:90) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (85:91) duplicated block id: 92 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (157:163) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (167:173) duplicated block id: 93 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java (467:473) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java (508:514) duplicated block id: 94 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java (235:241) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java (145:151) duplicated block id: 95 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (221:227) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (165:171) duplicated block id: 96 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (85:91) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (83:89) duplicated block id: 97 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java (77:83) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyWriter.java (73:79) duplicated block id: 98 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java (43:51) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java (44:52) duplicated block id: 99 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java (41:49) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java (37:45) duplicated block id: 100 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java (111:117) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java (92:98) duplicated block id: 101 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java (102:108) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (98:104) duplicated block id: 102 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) duplicated block id: 103 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) duplicated block id: 104 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java (182:187) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (177:182) duplicated block id: 105 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java (87:92) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java (164:169) duplicated block id: 106 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) duplicated block id: 107 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (114:120) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (109:115) duplicated block id: 108 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) duplicated block id: 109 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) duplicated block id: 110 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (114:120) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (115:121) duplicated block id: 111 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java (55:61) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java (88:94) duplicated block id: 112 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) duplicated block id: 113 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/JdbcSourceSchema.java (43:48) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerSchema.java (27:32) duplicated block id: 114 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) duplicated block id: 115 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 116 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 117 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47) duplicated block id: 118 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) duplicated block id: 119 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) duplicated block id: 120 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) duplicated block id: 121 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) duplicated block id: 122 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java (399:404) - flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java (423:428) duplicated block id: 123 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java (125:130) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java (64:69) duplicated block id: 124 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) duplicated block id: 125 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) duplicated block id: 126 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) duplicated block id: 127 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (115:121) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (109:115) duplicated block id: 128 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) duplicated block id: 129 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) duplicated block id: 130 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) duplicated block id: 131 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java (322:327) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java (224:229) duplicated block id: 132 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) duplicated block id: 133 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/JdbcSourceSchema.java (43:48) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresSchema.java (27:32) duplicated block id: 134 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/JdbcSourceSchema.java (43:48) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java (30:35) duplicated block id: 135 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) duplicated block id: 136 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 137 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) duplicated block id: 138 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) duplicated block id: 139 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java (126:131) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java (72:77) duplicated block id: 140 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) duplicated block id: 141 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java (78:83) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java (87:92) duplicated block id: 142 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (152:160) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java (144:152) duplicated block id: 143 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Type.java (53:58) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java (65:70) duplicated block id: 144 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java (78:83) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java (80:85) duplicated block id: 145 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java (87:92) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java (111:116) duplicated block id: 146 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImpl.java (72:77) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java (107:112) duplicated block id: 147 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 148 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) duplicated block id: 149 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) duplicated block id: 150 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImpl.java (72:77) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java (65:70) duplicated block id: 151 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (134:139) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (82:87) duplicated block id: 152 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) duplicated block id: 153 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (123:134) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (131:139) duplicated block id: 154 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) duplicated block id: 155 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) duplicated block id: 156 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) duplicated block id: 157 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) duplicated block id: 158 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java (95:102) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java (108:115) duplicated block id: 159 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/JdbcSourceSchema.java (43:48) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java (29:34) duplicated block id: 160 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47) duplicated block id: 161 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) duplicated block id: 162 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) duplicated block id: 163 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 164 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (64:70) duplicated block id: 165 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) duplicated block id: 166 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) duplicated block id: 167 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java (389:395) - flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java (479:485) duplicated block id: 168 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) duplicated block id: 169 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) duplicated block id: 170 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) duplicated block id: 171 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) duplicated block id: 172 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java (53:60) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java (51:58) duplicated block id: 173 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java (110:116) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java (241:247) duplicated block id: 174 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47) duplicated block id: 175 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java (81:86) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java (116:121) duplicated block id: 176 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java (68:78) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java (96:106) duplicated block id: 177 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) duplicated block id: 178 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47) duplicated block id: 179 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) duplicated block id: 180 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (122:128) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java (115:121) duplicated block id: 181 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 182 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) duplicated block id: 183 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) duplicated block id: 184 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) duplicated block id: 185 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java (171:177) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 186 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java (217:223) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 187 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) duplicated block id: 188 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (46:52) duplicated block id: 189 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) duplicated block id: 190 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (153:158) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java (64:69) duplicated block id: 191 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java (413:419) - flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java (479:485) duplicated block id: 192 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (162:168) - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) duplicated block id: 193 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 194 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (56:62) duplicated block id: 195 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java (88:94) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java (108:114) duplicated block id: 196 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 197 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (65:70) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (58:63) duplicated block id: 198 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java (53:60) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java (47:54) duplicated block id: 199 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java (31:37) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47) duplicated block id: 200 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java (125:130) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (153:158) duplicated block id: 201 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java (63:70) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java (98:105) duplicated block id: 202 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java (72:79) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java (52:59) duplicated block id: 203 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (114:120) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (122:128) duplicated block id: 204 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java (70:76) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47) duplicated block id: 205 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (105:111) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (234:240) duplicated block id: 206 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java (79:85) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java (41:47)