Places in code with 6 or more lines that are exactly the same.
| From Component --> To Component |
Duplicated Lines |
File Pairs | Details |
|---|---|---|---|
| flink-cdc-common (3%) --> flink-cdc-connect (<1%) |
664 | 553 file pairs | details... |
| flink-cdc-connect (<1%) --> flink-cdc-runtime (2%) |
501 | 268 file pairs | details... |
| flink-cdc-composer (10%) --> flink-cdc-connect (<1%) |
272 | 225 file pairs | details... |
| flink-cdc-common (1%) --> flink-cdc-runtime (<1%) |
176 | 138 file pairs | details... |
| flink-cdc-common (<1%) --> flink-cdc-composer (5%) |
144 | 119 file pairs | details... |
| flink-cdc-composer (3%) --> flink-cdc-runtime (<1%) |
98 | 56 file pairs | details... |
| Size | # | Folders | Files | Lines | Code |
|---|---|---|---|---|---|
| 89 | x 2 | flink-cdc-connect/flink-...tors/mysql/source/utilsflink-cdc-connect/flink-...ors/oracle/source/utils | 116:223 (39%)89:196 (39%) | view | |
| 83 | x 2 | flink-cdc-connect/flink-...e/source/assigner/stateflink-cdc-connect/flink-.../source/assigners/state | 30:158 (100%)29:157 (100%) | view | |
| 75 | x 2 | flink-cdc-connect/flink-.../connectors/mysql/utilsflink-cdc-connect/flink-...connectors/mysql/schema | 28:109 (37%)26:107 (39%) | view | |
| 75 | x 2 | flink-cdc-connect/flink-...onnectors/values/sourceflink-cdc-connect/flink-...onnectors/values/source | 417:500 (8%)944:1027 (8%) | view | |
| 63 | x 2 | flink-cdc-connect/flink-...dc/connectors/db2/tableflink-cdc-connect/flink-...nectors/sqlserver/table | 196:276 (34%)197:277 (34%) | view | |
| 58 | x 2 | flink-cdc-connect/flink-...cle/source/reader/fetchflink-cdc-connect/flink-...ver/source/reader/fetch | 257:321 (26%)247:311 (25%) | view | |
| 56 | x 2 | flink-cdc-connect/flink-...c/connectors/base/utilsflink-cdc-connect/flink-...tors/mysql/source/utils | 21:106 (100%)21:106 (100%) | view | |
| 52 | x 2 | flink-cdc-connect/flink-...ctors/db2/source/configflink-cdc-connect/flink-...sqlserver/source/config | 37:90 (92%)37:90 (92%) | view | |
| 51 | x 2 | flink-cdc-connect/flink-...dc/connectors/db2/tableflink-cdc-connect/flink-...connectors/oracle/table | 35:105 (82%)35:104 (82%) | view | |
| 51 | x 2 | flink-cdc-connect/flink-...dc/connectors/db2/tableflink-cdc-connect/flink-...nectors/sqlserver/table | 35:105 (82%)34:104 (82%) | view | |
| 51 | x 2 | flink-cdc-connect/flink-...connectors/oracle/tableflink-cdc-connect/flink-...nectors/sqlserver/table | 35:104 (82%)34:104 (82%) | view | |
| 48 | x 2 | flink-cdc-connect/flink-...onnectors/values/sourceflink-cdc-connect/flink-...onnectors/values/source | 575:632 (5%)1035:1092 (5%) | view | |
| 47 | x 2 | flink-cdc-connect/flink-...nnectors/postgres/tableflink-cdc-connect/flink-...nectors/sqlserver/table | 36:98 (62%)34:96 (75%) | view | |
| 47 | x 2 | flink-cdc-connect/flink-...dc/connectors/db2/tableflink-cdc-connect/flink-...nnectors/postgres/table | 35:97 (75%)36:98 (62%) | view | |
| 47 | x 2 | flink-cdc-connect/flink-...connectors/oracle/tableflink-cdc-connect/flink-...nnectors/postgres/table | 35:96 (75%)36:98 (62%) | view | |
| 47 | x 2 | flink-cdc-connect/flink-...c/connectors/base/utilsflink-cdc-connect/flink-...tors/mysql/source/utils | 141:207 (45%)455:521 (13%) | view | |
| 46 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/fetchflink-cdc-connect/flink-...cle/source/reader/fetch | 243:293 (20%)257:307 (21%) | view | |
| 46 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/fetchflink-cdc-connect/flink-...ver/source/reader/fetch | 243:293 (20%)247:297 (20%) | view | |
| 45 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/utilsflink-cdc-connect/flink-...tors/mysql/source/utils | 253:302 (17%)138:187 (20%) | view | |
| 45 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/utilsflink-cdc-connect/flink-...ors/oracle/source/utils | 253:302 (17%)111:160 (20%) | view | |
| 44 | x 2 | flink-cdc-connect/flink-...c/connectors/doris/sinkflink-cdc-connect/flink-...nnectors/oceanbase/sink | 47:99 (41%)51:103 (41%) | view | |
| 44 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/utilsflink-cdc-connect/flink-.../sqlserver/source/utils | 241:293 (17%)251:303 (15%) | view | |
| 42 | x 2 | flink-cdc-connect/flink-.../connectors/base/sourceflink-cdc-connect/flink-...nnectors/mysql/debezium | 46:102 (55%)47:103 (53%) | view | |
| 42 | x 2 | flink-cdc-connect/flink-...tors/mysql/source/utilsflink-cdc-connect/flink-...s/postgres/source/utils | 172:223 (18%)197:248 (16%) | view | |
| 42 | x 2 | flink-cdc-connect/flink-...ors/oracle/source/utilsflink-cdc-connect/flink-...s/postgres/source/utils | 145:196 (18%)197:248 (16%) | view | |
| 41 | x 2 | flink-cdc-connect/flink-...onnectors/values/sourceflink-cdc-connect/flink-...onnectors/values/source | 292:336 (4%)864:908 (4%) | view | |
| 41 | x 2 | flink-cdc-connect/flink-.../connectors/mysql/tableflink-cdc-connect/flink-...nnectors/postgres/table | 49:112 (65%)65:128 (54%) | view | |
| 41 | x 2 | flink-cdc-connect/flink-...connectors/mysql/sourceflink-cdc-connect/flink-...ors/mysql/source/config | 132:178 (15%)146:192 (17%) | view | |
| 40 | x 2 | flink-cdc-runtime/src/ma...tors/schema/distributedflink-cdc-runtime/src/ma...perators/schema/regular | 34:79 (100%)34:79 (100%) | view | |
| 40 | x 2 | flink-cdc-connect/flink-...link/cdc/debezium/utilsflink-cdc-runtime/src/ma...k/cdc/runtime/typeutils | 83:131 (28%)720:768 (6%) | view | |
| 39 | x 2 | flink-cdc-connect/flink-...onnectors/values/sourceflink-cdc-connect/flink-...onnectors/values/source | 174:216 (4%)816:858 (4%) | view | |
| 36 | x 2 | flink-cdc-connect/flink-.../connectors/mysql/utilsflink-cdc-connect/flink-...connectors/mysql/schema | 174:210 (18%)167:202 (18%) | view | |
| 36 | x 2 | flink-cdc-connect/flink-...tors/mysql/source/utilsflink-cdc-connect/flink-.../sqlserver/source/utils | 138:178 (16%)263:303 (12%) | view | |
| 36 | x 2 | flink-cdc-connect/flink-...ource/assigner/splitterflink-cdc-connect/flink-.../mysql/source/assigners | 31:89 (97%)31:89 (97%) | view | |
| 36 | x 2 | flink-cdc-connect/flink-...ors/oracle/source/utilsflink-cdc-connect/flink-.../sqlserver/source/utils | 111:151 (16%)263:303 (12%) | view | |
| 36 | x 2 | flink-cdc-connect/flink-...rs/base/source/assignerflink-cdc-connect/flink-.../mysql/source/assigners | 48:94 (33%)48:94 (34%) | view | |
| 35 | x 2 | flink-cdc-connect/flink-...onnectors/values/sourceflink-cdc-connect/flink-...onnectors/values/source | 187:224 (4%)307:344 (4%) | view | |
| 34 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/utilsflink-cdc-connect/flink-.../sqlserver/source/utils | 108:153 (13%)112:157 (12%) | view | |
| 34 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/utilsflink-cdc-connect/flink-.../sqlserver/source/utils | 181:226 (13%)181:226 (12%) | view | |
| 34 | x 2 | flink-cdc-connect/flink-.../base/source/meta/splitflink-cdc-connect/flink-...tors/mysql/source/split | 81:122 (39%)78:119 (38%) | view | |
| 33 | x 2 | flink-cdc-connect/flink-.../debezium/connector/db2flink-cdc-connect/flink-...ium/connector/sqlserver | 240:274 (10%)334:368 (7%) | view | |
| 32 | x 2 | flink-cdc-connect/flink-...c/connectors/doris/sinkflink-cdc-connect/flink-...nnectors/oceanbase/sink | 111:142 (16%)66:97 (29%) | view | |
| 32 | x 2 | flink-cdc-connect/flink-...connectors/mysql/sourceflink-cdc-connect/flink-...ors/mysql/source/config | 183:217 (12%)204:238 (13%) | view | |
| 32 | x 2 | flink-cdc-connect/flink-...rs/base/source/assignerflink-cdc-connect/flink-.../mysql/source/assigners | 146:212 (30%)146:212 (30%) | view | |
| 31 | x 2 | flink-cdc-connect/flink-...cle/source/reader/fetchflink-cdc-connect/flink-...cle/source/reader/fetch | 129:162 (15%)179:212 (15%) | view | |
| 31 | x 2 | flink-cdc-connect/flink-...cle/source/reader/fetchflink-cdc-connect/flink-...cle/source/reader/fetch | 129:162 (15%)229:262 (15%) | view | |
| 31 | x 2 | flink-cdc-connect/flink-...rs/base/source/assignerflink-cdc-connect/flink-.../mysql/source/assigners | 96:139 (29%)96:139 (29%) | view | |
| 31 | x 2 | flink-cdc-connect/flink-...cle/source/reader/fetchflink-cdc-connect/flink-...cle/source/reader/fetch | 179:212 (15%)229:262 (15%) | view | |
| 30 | x 2 | flink-cdc-connect/flink-...onnectors/values/sourceflink-cdc-connect/flink-...onnectors/values/source | 174:207 (3%)417:449 (3%) | view | |
| 30 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/fetchflink-cdc-connect/flink-...ver/source/reader/fetch | 275:314 (17%)288:327 (17%) | view |
| Size | # | Folders | Files | Lines | Code |
|---|---|---|---|---|---|
| 51 | x 2 | flink-cdc-connect/flink-...ctors/db2/source/configflink-cdc-connect/flink-...sqlserver/source/config | 36:88 36:88 | view | |
| 49 | x 2 | flink-cdc-runtime/src/ma...k/cdc/runtime/typeutilsflink-cdc-connect/flink-...link/cdc/debezium/utils | 719:769 82:132 | view | |
| 48 | x 3 | flink-cdc-connect/flink-...ors/oracle/source/utilsflink-cdc-connect/flink-...ectors/db2/source/utilsflink-cdc-connect/flink-...tors/mysql/source/utils | 111:162 253:304 138:189 | view | |
| 33 | x 5 | flink-cdc-connect/flink-...ors/oracle/source/utilsflink-cdc-connect/flink-...ectors/db2/source/utilsflink-cdc-connect/flink-.../sqlserver/source/utilsflink-cdc-connect/flink-...tors/mysql/source/utilsflink-cdc-connect/flink-...s/postgres/source/utils | 164:198 194:228 194:228 191:225 216:250 | view | |
| 31 | x 2 | flink-cdc-runtime/src/ma...k/cdc/runtime/typeutilsflink-cdc-connect/flink-...link/cdc/debezium/utils | 580:614 46:80 | view | |
| 30 | x 2 | flink-cdc-connect/flink-...nnectors/oceanbase/sinkflink-cdc-connect/flink-...c/connectors/doris/sink | 67:98 112:143 | view | |
| 30 | x 2 | flink-cdc-connect/flink-...c/connectors/base/utilsflink-cdc-connect/flink-...tors/mysql/source/utils | 141:176 455:490 | view | |
| 29 | x 2 | flink-cdc-connect/flink-...ource/assigner/splitterflink-cdc-connect/flink-.../mysql/source/assigners | 446:480 288:323 | view | |
| 29 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/utilsflink-cdc-connect/flink-...tors/mysql/source/utils | 89:120 100:131 | view | |
| 24 | x 2 | flink-cdc-connect/flink-...ctors/base/source/utilsflink-cdc-connect/flink-...s/postgres/source/utils | 110:138 44:72 | view | |
| 24 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/utilsflink-cdc-connect/flink-.../sqlserver/source/utils | 122:150 126:154 | view | |
| 22 | x 2 | flink-cdc-runtime/src/ma...perators/schema/regularflink-cdc-runtime/src/ma...perators/schema/regular | 136:163 196:223 | view | |
| 22 | x 2 | flink-cdc-connect/flink-...ource/assigner/splitterflink-cdc-connect/flink-.../mysql/source/assigners | 225:250 428:453 | view | |
| 21 | x 2 | flink-cdc-connect/flink-...ctors/db2/source/offsetflink-cdc-connect/flink-...sqlserver/source/offset | 58:82 57:81 | view | |
| 20 | x 2 | flink-cdc-connect/flink-...rs/base/source/assignerflink-cdc-connect/flink-.../mysql/source/assigners | 657:683 578:604 | view | |
| 19 | x 2 | flink-cdc-connect/flink-.../base/source/meta/splitflink-cdc-connect/flink-...tors/mysql/source/split | 173:193 173:193 | view | |
| 18 | x 2 | flink-cdc-connect/flink-...nnectors/oceanbase/sinkflink-cdc-connect/flink-...c/connectors/doris/sink | 64:83 81:100 | view | |
| 17 | x 2 | flink-cdc-connect/flink-...c/connectors/base/utilsflink-cdc-connect/flink-...tors/mysql/source/utils | 28:48 28:48 | view | |
| 17 | x 2 | flink-cdc-connect/flink-...rs/base/source/assignerflink-cdc-connect/flink-.../mysql/source/assigners | 154:172 154:172 | view | |
| 17 | x 2 | flink-cdc-connect/flink-...tors/base/source/readerflink-cdc-connect/flink-...ors/mysql/source/reader | 362:382 502:522 | view | |
| 17 | x 2 | flink-cdc-connect/flink-...base/source/meta/offsetflink-cdc-connect/flink-...ors/mysql/source/offset | 47:65 146:164 | view | |
| 15 | x 2 | flink-cdc-common/src/mai.../flink/cdc/common/utilsflink-cdc-common/src/mai.../flink/cdc/common/utils | 587:604 603:620 | view | |
| 15 | x 3 | flink-cdc-connect/flink-...c/connectors/tidb/tableflink-cdc-connect/flink-...dc/connectors/db2/tableflink-cdc-connect/flink-...nectors/sqlserver/table | 106:125 224:243 225:244 | view | |
| 14 | x 2 | flink-cdc-runtime/src/ma.../runtime/operators/sinkflink-cdc-runtime/src/ma.../runtime/operators/sink | 246:261 164:179 | view | |
| 14 | x 2 | flink-cdc-connect/flink-...c/connectors/base/utilsflink-cdc-connect/flink-...tors/mysql/source/utils | 83:98 83:98 | view | |
| 13 | x 2 | flink-cdc-runtime/src/ma...tors/schema/distributedflink-cdc-runtime/src/ma...perators/schema/regular | 66:80 66:80 | view | |
| 13 | x 2 | flink-cdc-connect/flink-...ectors/kafka/json/canalflink-cdc-connect/flink-...ors/kafka/serialization | 83:97 71:85 | view | |
| 13 | x 3 | flink-cdc-connect/flink-...nnectors/oceanbase/sinkflink-cdc-connect/flink-...c/connectors/doris/sinkflink-cdc-connect/flink-...lasticsearch/serializer | 157:172 153:168 173:188 | view | |
| 13 | x 2 | flink-cdc-connect/flink-.../base/source/meta/splitflink-cdc-connect/flink-...tors/mysql/source/split | 109:123 106:120 | view | |
| 12 | x 2 | flink-cdc-runtime/src/ma...ime/operators/transformflink-cdc-runtime/src/ma...ime/operators/transform | 60:73 37:50 | view | |
| 12 | x 2 | flink-cdc-runtime/src/ma...tors/schema/distributedflink-cdc-runtime/src/ma...perators/schema/regular | 45:58 45:58 | view | |
| 12 | x 2 | flink-cdc-connect/flink-.../connectors/base/sourceflink-cdc-connect/flink-...nnectors/mysql/debezium | 59:74 60:75 | view | |
| 12 | x 2 | flink-cdc-connect/flink-.../base/source/meta/splitflink-cdc-connect/flink-...tors/mysql/source/split | 85:98 82:95 | view | |
| 11 | x 2 | flink-cdc-runtime/src/ma.../runtime/operators/sinkflink-cdc-runtime/src/ma.../runtime/operators/sink | 271:283 189:201 | view | |
| 11 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/fetchflink-cdc-connect/flink-...ver/source/reader/fetch | 290:302 303:315 | view | |
| 11 | x 2 | flink-cdc-connect/flink-...link/cdc/debezium/tableflink-cdc-connect/flink-...link/cdc/debezium/event | 662:676 423:437 | view | |
| 10 | x 2 | flink-cdc-runtime/src/ma...tors/schema/distributedflink-cdc-runtime/src/ma...perators/schema/regular | 47:58 46:57 | view | |
| 10 | x 2 | flink-cdc-common/src/mai...e/flink/cdc/common/dataflink-cdc-common/src/mai...e/flink/cdc/common/data | 101:112 74:85 | view | |
| 10 | x 2 | flink-cdc-common/src/mai...k/cdc/common/exceptionsflink-cdc-common/src/mai...k/cdc/common/exceptions | 42:53 57:68 | view | |
| 10 | x 2 | flink-cdc-connect/flink-...c/connectors/base/utilsflink-cdc-connect/flink-...tors/mysql/source/utils | 71:84 301:314 | view | |
| 10 | x 2 | flink-cdc-connect/flink-...e/source/assigner/stateflink-cdc-connect/flink-.../source/assigners/state | 69:80 68:79 | view | |
| 10 | x 2 | flink-cdc-connect/flink-...e/source/assigner/stateflink-cdc-connect/flink-.../source/assigners/state | 405:416 358:369 | view | |
| 10 | x 2 | flink-cdc-connect/flink-.../connectors/base/sourceflink-cdc-connect/flink-...nnectors/mysql/debezium | 89:100 90:101 | view | |
| 10 | x 2 | flink-cdc-connect/flink-.../base/source/meta/splitflink-cdc-connect/flink-...tors/mysql/source/split | 61:72 61:72 | view | |
| 10 | x 2 | flink-cdc-connect/flink-...ectors/db2/source/fetchflink-cdc-connect/flink-...ver/source/reader/fetch | 276:287 289:300 | view | |
| 9 | x 3 | flink-cdc-connect/flink-...nnectors/oceanbase/sinkflink-cdc-connect/flink-...c/connectors/doris/sinkflink-cdc-connect/flink-...lasticsearch/serializer | 145:155 141:151 161:171 | view | |
| 9 | x 2 | flink-cdc-connect/flink-...nectors/base/relationalflink-cdc-connect/flink-...s/postgres/source/fetch | 244:255 73:83 | view | |
| 9 | x 2 | flink-cdc-connect/flink-...ource/assigner/splitterflink-cdc-connect/flink-.../mysql/source/assigners | 47:57 47:57 | view | |
| 9 | x 2 | flink-cdc-connect/flink-...ource/assigner/splitterflink-cdc-connect/flink-.../mysql/source/assigners | 70:80 70:80 | view | |
| 9 | x 4 | flink-cdc-connect/flink-...connectors/oracle/tableflink-cdc-connect/flink-...dc/connectors/db2/tableflink-cdc-connect/flink-...nectors/sqlserver/tableflink-cdc-connect/flink-...nnectors/postgres/table | 244:254 267:277 268:278 269:279 | view |
