22 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (192:213, 23%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/TableSchemaInfo.java (134:155, 17%)

21 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Selectors.java (75:105, 33%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/Selectors.java (64:100, 42%)

14 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultDataChangeEventHashFunctionProvider.java (78:92, 31%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/sink/MaxComputeHashFunctionProvider.java (84:98, 27%)

12 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java (185:196, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java (405:416, 3%)

11 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (203:213, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java (265:275, 2%)

11 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (180:190, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/TableSchemaInfo.java (116:126, 8%)

11 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (202:212, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java (150:160, 4%)

10 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (234:246, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java (343:355, 2%)

10 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java (217:229, 9%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java (485:497, 2%)

9 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Selectors.java (111:123, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/Selectors.java (104:116, 18%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:103, 17%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:122, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:129, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:98, 17%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:98, 17%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:103, 17%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:98, 17%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:115, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:103, 15%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:99, 15%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:89, 19%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java (174:181, 7%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java (389:396, 2%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:132, 6%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:118, 15%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:89, 19%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:128, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:118, 15%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:128, 13%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:129, 13%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:103, 15%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:129, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:103, 15%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:89, 19%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:132, 6%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:99, 15%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:132, 6%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:111, 16%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (192:199, 8%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java (249:256, 2%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:118, 15%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:122, 16%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:103, 17%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:122, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:111, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:115, 13%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:62, 19%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:111, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:99, 15%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:115, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:128, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:149, 7%)

8 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (192:199, 8%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java (142:149, 3%)

7 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (238:246, 7%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriterHelper.java (142:150, 3%)

7 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (238:246, 7%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java (194:202, 4%)

7 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (238:246, 7%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/TableSchemaInfo.java (176:184, 5%)

7 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (238:246, 7%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java (201:209, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:146, 5%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:59, 14%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java (161:166, 5%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java (374:379, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:59, 14%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:59, 14%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:146, 5%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:146, 5%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:146, 5%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:146, 5%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:146, 5%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (230:235, 6%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java (185:190, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:146, 5%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:146, 5%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/DataTypeUtils.java (92:97, 4%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java (62:67, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java (140:146, 5%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java (160:166, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java (140:146, 5%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java (333:339, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java (300:306, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:59, 14%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java (180:185, 6%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java (234:239, 1%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java (134:140, 7%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java (210:216, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java (84:90, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java (121:127, 12%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java (53:59, 14%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java (163:169, 3%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java (57:63, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java (101:107, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java (58:64, 24%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java (105:111, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java (259:265, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java (119:125, 9%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java (69:75, 16%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java (35:41, 30%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java (271:277, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java (65:71, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java (140:146, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java (81:87, 6%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java (41:47, 19%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java (171:177, 4%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java (51:57, 18%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java (139:145, 8%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java (66:72, 21%)

6 duplicated lines in:
  - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%)
  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java (261:267, 2%)