duplicated block id: 1
size: 11 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTimeType.java (29:46)
 - src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTimestampType.java (29:41)

duplicated block id: 2
size: 8 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java (48:55)
 - src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java (59:66)

duplicated block id: 3
size: 7 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/GeometryType.java (35:45)
 - src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/PointType.java (35:44)

duplicated block id: 4
size: 7 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/converter/schema/SchemaChangeManager.java (167:174)
 - src/main/java/org/apache/doris/kafka/connector/service/RestService.java (347:354)

duplicated block id: 5
size: 6 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java (48:53)
 - src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java (63:68)

duplicated block id: 6
size: 6 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectFloat64Type.java (33:40)
 - src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/VariableScaleDecimalType.java (56:68)

duplicated block id: 7
size: 6 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java (63:68)
 - src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java (59:64)

duplicated block id: 8
size: 6 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java (89:95)
 - src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommittable.java (79:85)

duplicated block id: 9
size: 6 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java (109:115)
 - src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java (89:95)

duplicated block id: 10
size: 6 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java (109:115)
 - src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommittable.java (79:85)

duplicated block id: 11
size: 6 cleaned lines of code
in 2 files:
 - src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java (105:112)
 - src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java (141:148)