duplicated block id: 1 size: 86 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java (132:270) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormat.java (98:228) duplicated block id: 2 size: 25 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialect.java (130:161) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractPostgresCompatibleDialect.java (75:110) duplicated block id: 3 size: 23 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/derby/dialect/DerbyDialect.java (78:110) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialect.java (98:130) duplicated block id: 4 size: 22 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/derby/dialect/DerbyDialect.java (78:109) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractPostgresCompatibleDialect.java (75:107) duplicated block id: 5 size: 22 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialect.java (98:129) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractPostgresCompatibleDialect.java (75:107) duplicated block id: 6 size: 22 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialect.java (98:129) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialect.java (130:158) duplicated block id: 7 size: 22 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/derby/dialect/DerbyDialect.java (78:109) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialect.java (130:158) duplicated block id: 8 size: 18 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java (294:320) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormat.java (261:287) duplicated block id: 9 size: 11 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (145:155) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractPostgresCompatibleDialect.java (98:108) duplicated block id: 10 size: 11 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialect.java (149:159) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (145:155) duplicated block id: 11 size: 10 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/derby/dialect/DerbyDialect.java (100:109) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (145:154) duplicated block id: 12 size: 10 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialect.java (120:129) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (145:154) duplicated block id: 13 size: 9 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaSinkStateSerializer.java (146:156) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XidSerializer.java (127:137) duplicated block id: 14 size: 9 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXidSerializer.java (122:132) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaSinkStateSerializer.java (146:156) duplicated block id: 15 size: 9 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXidSerializer.java (122:132) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XidSerializer.java (127:137) duplicated block id: 16 size: 8 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/AbstractJdbcRowConverter.java (153:163) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleRowConverter.java (106:113) duplicated block id: 17 size: 8 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/KeyedBatchStatementExecutor.java (75:86) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/SimpleBatchStatementExecutor.java (71:82) duplicated block id: 18 size: 7 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalog.java (92:98) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/PostgresCatalog.java (145:152) duplicated block id: 19 size: 7 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSink.java (99:107) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java (215:223) duplicated block id: 20 size: 7 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcOutputFormatBuilder.java (182:188) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcOutputFormatBuilder.java (219:225) duplicated block id: 21 size: 7 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java (85:92) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java (108:115) duplicated block id: 22 size: 7 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java (71:77) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalog.java (64:70) duplicated block id: 23 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXidSerializer.java (89:98) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaSinkStateSerializer.java (113:122) duplicated block id: 24 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb/catalog/CrateDBCatalog.java (57:62) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/PostgresCatalog.java (76:81) duplicated block id: 25 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java (46:51) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/PostgresCatalog.java (77:82) duplicated block id: 26 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb/catalog/CrateDBCatalog.java (64:69) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/PostgresCatalog.java (83:88) duplicated block id: 27 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialect.java (108:119) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (138:143) duplicated block id: 28 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/derby/dialect/DerbyDialect.java (88:99) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (138:143) duplicated block id: 29 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialect.java (69:76) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (65:72) duplicated block id: 30 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (138:143) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractPostgresCompatibleDialect.java (85:97) duplicated block id: 31 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (90:95) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (99:104) duplicated block id: 32 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java (71:76) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/PostgresCatalog.java (76:81) duplicated block id: 33 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java (97:102) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb/catalog/CrateDBCatalog.java (57:62) duplicated block id: 34 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaSinkStateSerializer.java (114:123) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XidSerializer.java (96:105) duplicated block id: 35 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/PostgresTablePath.java (93:100) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java (73:79) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java (97:102) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtils.java (46:51) duplicated block id: 37 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java (97:102) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java (71:76) duplicated block id: 38 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java (97:102) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalog.java (64:69) duplicated block id: 39 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialect.java (140:148) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialect.java (138:143) duplicated block id: 40 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb/catalog/CrateDBCatalog.java (57:62) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalog.java (64:69) duplicated block id: 41 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtils.java (46:51) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb/catalog/CrateDBCatalog.java (57:62) duplicated block id: 42 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java (56:62) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java (73:79) duplicated block id: 43 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java (56:62) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/PostgresTablePath.java (93:100) duplicated block id: 44 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalog.java (64:69) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/PostgresCatalog.java (76:81) duplicated block id: 45 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java (71:76) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb/catalog/CrateDBCatalog.java (57:62) duplicated block id: 46 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java (71:76) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtils.java (46:51) duplicated block id: 47 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtils.java (46:51) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/PostgresCatalog.java (76:81) duplicated block id: 48 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java (97:102) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/PostgresCatalog.java (76:81) duplicated block id: 49 size: 6 cleaned lines of code in 2 files: - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtils.java (46:51) - flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySqlCatalog.java (64:69)