duplicated block id: 1
size: 33 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/DateUtil.java (41:93)
 - flink_sink_adbpg_datastream/src/main/java/DateUtil.java (36:88)

duplicated block id: 2
size: 29 cleaned lines of code
in 2 files:
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (691:729)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (832:870)

duplicated block id: 3
size: 17 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcRowConverter.java (156:175)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StreamingServerRowConverter.java (170:186)

duplicated block id: 4
size: 15 cleaned lines of code
in 2 files:
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (695:716)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (916:937)

duplicated block id: 5
size: 15 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcRowConverter.java (66:89)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StreamingServerRowConverter.java (63:86)

duplicated block id: 6
size: 15 cleaned lines of code
in 2 files:
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (836:857)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (916:937)

duplicated block id: 7
size: 14 cleaned lines of code
in 2 files:
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (719:737)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (940:958)

duplicated block id: 8
size: 12 cleaned lines of code
in 2 files:
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (553:566)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (591:603)

duplicated block id: 9
size: 10 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/DateUtil.java (18:32)
 - flink_sink_adbpg_datastream/src/main/java/DateUtil.java (13:27)

duplicated block id: 10
size: 10 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcTypeUtil.java (49:61)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StreamingServerTypeUtil.java (45:57)

duplicated block id: 11
size: 10 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/sink/AdbpgOutputFormat.java (246:257)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (268:279)

duplicated block id: 12
size: 10 cleaned lines of code
in 2 files:
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (860:870)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (940:950)

duplicated block id: 13
size: 10 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/AdbpgOptions.java (229:238)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/AdbpgOptions.java (246:255)

duplicated block id: 14
size: 10 cleaned lines of code
in 2 files:
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (382:394)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (407:419)

duplicated block id: 15
size: 10 cleaned lines of code
in 2 files:
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (683:692)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (904:913)

duplicated block id: 16
size: 9 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcTypeUtil.java (32:45)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StreamingServerTypeUtil.java (28:41)

duplicated block id: 17
size: 8 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/sink/AdbpgOutputFormat.java (100:107)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (35:42)

duplicated block id: 18
size: 7 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcRowConverter.java (294:300)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StreamingServerRowConverter.java (293:299)

duplicated block id: 19
size: 7 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StreamingServerRowConverter.java (293:299)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StringFormatRowConverter.java (140:146)

duplicated block id: 20
size: 7 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/sink/AdbpgOutputFormat.java (283:292)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (804:812)

duplicated block id: 21
size: 7 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcRowConverter.java (294:300)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StringFormatRowConverter.java (140:146)

duplicated block id: 22
size: 6 cleaned lines of code
in 2 files:
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (81:86)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (102:107)

duplicated block id: 23
size: 6 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/sink/AdbpgOutputFormat.java (345:350)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (281:286)

duplicated block id: 24
size: 6 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/sink/AdbpgOutputFormat.java (1013:1019)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (560:566)

duplicated block id: 25
size: 6 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/AdbpgDialect.java (170:175)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/AdbpgDialect.java (214:219)

duplicated block id: 26
size: 6 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/sink/AdbpgOutputFormat.java (1013:1019)
 - flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java (597:603)

duplicated block id: 27
size: 6 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/AdbpgDialect.java (195:200)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/AdbpgDialect.java (257:262)

duplicated block id: 28
size: 6 cleaned lines of code
in 2 files:
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcRowConverter.java (193:198)
 - flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StreamingServerRowConverter.java (196:201)