duplicated block id: 1 size: 18 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RowDataSerializer.java (115:144) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RowSerializer.java (61:90) duplicated block id: 2 size: 14 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java (55:70) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (56:71) duplicated block id: 3 size: 12 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java (462:473) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java (544:555) duplicated block id: 4 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java (88:98) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java (111:121) duplicated block id: 5 size: 11 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (29:39) - flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java (128:138) duplicated block id: 6 size: 10 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java (199:211) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java (277:289) duplicated block id: 7 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (69:77) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataLookupFunction.java (75:83) duplicated block id: 8 size: 9 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java (340:351) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java (121:132) duplicated block id: 9 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java (100:107) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java (130:137) duplicated block id: 10 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java (121:131) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (111:121) duplicated block id: 11 size: 8 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java (52:61) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java (37:46) duplicated block id: 12 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java (46:52) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (47:53) duplicated block id: 13 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java (211:218) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java (291:298) duplicated block id: 14 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (87:94) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataLookupFunction.java (92:99) duplicated block id: 15 size: 7 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java (73:79) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java (72:78) duplicated block id: 16 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java (73:78) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataLookupFunction.java (78:83) duplicated block id: 17 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java (90:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (61:67) duplicated block id: 18 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 (48:54) duplicated block id: 19 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java (80:86) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (48:54) duplicated block id: 20 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java (90:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (35:41) duplicated block id: 21 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (139:144) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java (148:153) duplicated block id: 22 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (104:110) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java (90:96) duplicated block id: 23 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java (61:67) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (35:41) duplicated block id: 24 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java (52:58) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (61:67) duplicated block id: 25 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/models/QueryPlan.java (52:58) duplicated block id: 26 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (104:110) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java (52:58) duplicated block id: 27 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/models/Schema.java (80:86) duplicated block id: 28 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java (90:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java (52:58) duplicated block id: 29 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java (61:67) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (48:54) duplicated block id: 30 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (104:110) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java (80:86) duplicated block id: 31 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (48:54) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (61:67) duplicated block id: 32 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java (90:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java (61:67) duplicated block id: 33 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (104:110) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (61:67) duplicated block id: 34 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (104:110) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (48:54) duplicated block id: 35 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java (90:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (48:54) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java (52:58) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java (80:86) duplicated block id: 37 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/models/Field.java (90:96) duplicated block id: 38 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 (35:41) duplicated block id: 39 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java (52:58) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (35:41) duplicated block id: 40 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 (61:67) duplicated block id: 41 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java (61:67) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (61:67) duplicated block id: 42 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 (104:110) duplicated block id: 43 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java (90:96) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java (80:86) duplicated block id: 44 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java (52:58) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java (61:67) duplicated block id: 45 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java (78:84) - flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java (92:98) duplicated block id: 46 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 (89:96) duplicated block id: 47 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (48:54) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (35:41) duplicated block id: 48 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (35:41) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (61:67) duplicated block id: 49 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java (80:86) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java (61:67) duplicated block id: 50 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (104:110) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (35:41) duplicated block id: 51 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java (80:86) - flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java (61:67) duplicated block id: 52 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/models/Tablet.java (61:67) duplicated block id: 53 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java (241:249) - flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java (225:233) duplicated block id: 54 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java (52:58) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java (48:54) duplicated block id: 55 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java (104:110) - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java (61:67) duplicated block id: 56 size: 6 cleaned lines of code in 2 files: - flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java (80:86) - flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java (35:41)