26 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/DynamicBucketRow.java (59:100, 41%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkRowWrapper.java (61:102, 14%)

25 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/DynamicBucketRow.java (59:99, 40%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkRowData.java (68:108, 14%)

8 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/utils/OffsetRow.java (53:64, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (69:80, 8%)

8 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/casting/CastedRow.java (66:77, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (69:80, 8%)

8 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/DynamicBucketRow.java (49:60, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (69:80, 8%)

8 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/casting/DefaultValueRow.java (57:68, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (69:80, 8%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java (158:164, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java (43:49, 25%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java (43:49, 27%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java (91:97, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java (57:63, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java (147:153, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java (147:153, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java (182:188, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java (126:132, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (317:323, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (111:117, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java (62:68, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (353:359, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/Schema.java (161:167, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/stats/BinaryTableStats.java (118:124, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java (34:40, 35%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java (136:142, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java (147:153, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java (146:152, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (411:417, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java (40:46, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java (88:94, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java (91:97, 9%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (90:96, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java (136:142, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java (79:85, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (278:284, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java (157:163, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java (40:46, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (197:203, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java (150:156, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (90:96, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java (43:49, 25%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (317:323, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java (136:142, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java (88:94, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java (34:40, 35%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java (43:49, 27%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/stats/BinaryTableStats.java (118:124, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (139:145, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java (140:146, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java (88:94, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java (88:94, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java (150:156, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (111:117, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java (150:156, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java (87:93, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java (43:49, 27%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java (34:40, 35%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java (88:94, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (242:248, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java (43:49, 25%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/Schema.java (161:167, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java (62:68, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java (91:97, 9%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java (140:146, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java (126:132, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java (144:150, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (90:96, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java (87:93, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java (91:97, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (411:417, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (353:359, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java (91:97, 9%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java (144:150, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (139:145, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java (79:85, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java (40:46, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (90:96, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java (79:85, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java (40:46, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java (43:49, 25%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (411:417, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java (136:142, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java (87:93, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java (91:97, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java (182:188, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/Schema.java (161:167, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java (146:152, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java (40:46, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (197:203, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (317:323, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java (140:146, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java (91:97, 9%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java (87:93, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (242:248, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java (57:63, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (353:359, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java (87:93, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java (57:63, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java (157:163, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java (140:146, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java (87:93, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/NewFilesIncrement.java (53:59, 17%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/stats/BinaryTableStats.java (118:124, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java (91:97, 9%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java (144:150, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java (157:163, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (411:417, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (242:248, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java (91:97, 9%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (411:417, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/NewFilesIncrement.java (53:59, 17%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java (144:150, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java (62:68, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (353:359, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java (157:163, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java (62:68, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java (182:188, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java (150:156, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java (87:93, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/NewFilesIncrement.java (53:59, 17%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (144:150, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/stats/BinaryTableStats.java (118:124, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java (126:132, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java (158:164, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/Schema.java (161:167, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java (235:241, 4%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java (158:164, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java (40:46, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/Schema.java (161:167, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java (146:152, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (139:145, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java (87:93, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (90:96, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java (57:63, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (242:248, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/NewFilesIncrement.java (53:59, 17%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java (140:146, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (317:323, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java (144:150, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/stats/BinaryTableStats.java (118:124, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java (91:97, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java (43:49, 25%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java (182:188, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java (57:63, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java (235:241, 4%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java (43:49, 27%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java (136:142, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java (91:97, 9%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java (146:152, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (90:96, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java (43:49, 27%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java (34:40, 35%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (144:150, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java (40:46, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (139:145, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java (88:94, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (111:117, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java (34:40, 35%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (278:284, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/NewFilesIncrement.java (53:59, 17%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java (57:63, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java (91:97, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java (150:156, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (278:284, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java (150:156, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java (136:142, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java (235:241, 4%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (242:248, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (353:359, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (317:323, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java (62:68, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java (126:132, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java (144:150, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (317:323, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java (144:150, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java (235:241, 4%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java (182:188, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/NewFilesIncrement.java (53:59, 17%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (144:150, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java (150:156, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (144:150, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java (146:152, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java (158:164, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java (40:46, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java (126:132, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java (79:85, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (144:150, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (411:417, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/NewFilesIncrement.java (53:59, 17%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (111:117, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java (88:94, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (139:145, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (411:417, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java (157:163, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java (57:63, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (317:323, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java (157:163, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java (157:163, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (278:284, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (197:203, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java (91:97, 9%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java (126:132, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java (79:85, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (90:96, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java (126:132, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java (136:142, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java (146:152, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java (34:40, 35%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java (43:49, 27%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/stats/BinaryTableStats.java (118:124, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java (157:163, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java (144:150, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java (136:142, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java (34:40, 35%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java (157:163, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (90:96, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (90:96, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java (62:68, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (197:203, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (197:203, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java (144:150, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/stats/BinaryTableStats.java (118:124, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java (57:63, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/NewFilesIncrement.java (53:59, 17%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java (40:46, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java (91:97, 9%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/Schema.java (161:167, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java (146:152, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java (79:85, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java (136:142, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java (43:49, 27%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java (43:49, 25%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java (34:40, 35%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (139:145, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java (158:164, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java (235:241, 4%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (197:203, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java (126:132, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (278:284, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java (147:153, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java (79:85, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java (88:94, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (144:150, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java (87:93, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (144:150, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java (79:85, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java (140:146, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java (147:153, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (278:284, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (242:248, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java (140:146, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java (182:188, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (411:417, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java (43:49, 27%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (139:145, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java (62:68, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (317:323, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java (157:163, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java (88:94, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java (91:97, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (278:284, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java (235:241, 4%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java (88:94, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/stats/BinaryTableStats.java (118:124, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java (62:68, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java (91:97, 9%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java (146:152, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java (34:40, 35%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (139:145, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (139:145, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/Schema.java (161:167, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (242:248, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java (87:93, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java (144:150, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (353:359, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java (158:164, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java (79:85, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java (79:85, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (111:117, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java (235:241, 4%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (197:203, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java (147:153, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittableSerializer.java (98:104, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/WrappedManifestCommittableSerializer.java (107:113, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java (147:153, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java (235:241, 4%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/stats/BinaryTableStats.java (118:124, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java (62:68, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (139:145, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java (90:96, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java (147:153, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java (140:146, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java (91:97, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java (146:152, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java (150:156, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/stats/BinaryTableStats.java (118:124, 8%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (144:150, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (242:248, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java (146:152, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (411:417, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java (136:142, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java (34:40, 35%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (197:203, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java (182:188, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java (43:49, 25%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java (158:164, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (111:117, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java (43:49, 27%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/Schema.java (161:167, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java (43:49, 25%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (111:117, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java (140:146, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java (140:146, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java (126:132, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (197:203, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java (62:68, 11%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java (126:132, 6%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/Schema.java (161:167, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java (158:164, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java (43:49, 25%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (411:417, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java (147:153, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (353:359, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (197:203, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (111:117, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java (91:97, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java (91:97, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java (79:85, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java (235:241, 4%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java (150:156, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java (158:164, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java (182:188, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (242:248, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java (182:188, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/Schema.java (161:167, 3%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (317:323, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java (150:156, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (317:323, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java (182:188, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java (40:46, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (353:359, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (278:284, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java (57:63, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (111:117, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/PlaceholderSplit.java (92:98, 11%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (353:359, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/NewFilesIncrement.java (53:59, 17%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java (57:63, 13%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/NewFilesIncrement.java (53:59, 17%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java (108:114, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (278:284, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (111:117, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java (80:86, 14%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (278:284, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java (147:153, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java (91:97, 12%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java (43:49, 28%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (242:248, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java (235:241, 4%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplit.java (64:70, 18%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (353:359, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogOffsetCommittable.java (53:59, 23%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java (43:49, 25%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (144:150, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java (61:67, 13%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java (43:49, 27%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java (144:150, 2%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java (73:79, 10%)

6 duplicated lines in:
  - paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java (158:164, 5%)
  - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/BinaryRowTypeSerializer.java (102:108, 7%)