duplicated block id: 1 size: 40 cleaned lines of code in 2 files: - paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/HadoopCompliantFileIO.java (118:207) - paimon-filesystems/paimon-s3-impl/src/main/java/org/apache/paimon/s3/HadoopCompliantFileIO.java (118:207) duplicated block id: 2 size: 28 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java (187:221) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java (203:237) duplicated block id: 3 size: 19 cleaned lines of code in 2 files: - paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/OperatingSystem.java (103:125) - paimon-common/src/main/java/org/apache/paimon/utils/OperatingSystem.java (103:125) duplicated block id: 4 size: 16 cleaned lines of code in 2 files: - paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkScan.java (86:107) - paimon-spark/paimon-spark-2/src/main/java/org/apache/paimon/spark/SparkDataSourceReader.java (94:115) duplicated block id: 5 size: 15 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java (169:185) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java (271:287) duplicated block id: 6 size: 12 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkRowWrapper.java (304:317) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkRowData.java (320:333) duplicated block id: 7 size: 11 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/Projection.java (94:106) - paimon-common/src/main/java/org/apache/paimon/utils/Projection.java (162:174) duplicated block id: 8 size: 10 cleaned lines of code in 2 files: - paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/OSSFileIO.java (143:154) - paimon-filesystems/paimon-s3-impl/src/main/java/org/apache/paimon/s3/S3FileIO.java (146:157) duplicated block id: 9 size: 10 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-action/src/main/java/org/apache/paimon/flink/action/FlinkActions.java (32:45) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/FlinkActions.java (37:50) duplicated block id: 10 size: 10 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/canal/CanalRecordParser.java (308:319) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java (446:457) duplicated block id: 11 size: 9 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTableCommittable.java (108:118) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/Committable.java (76:86) duplicated block id: 12 size: 9 cleaned lines of code in 2 files: - paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageSerializer.java (102:112) - paimon-core/src/main/java/org/apache/paimon/table/sink/CompactionTaskSerializer.java (92:102) duplicated block id: 13 size: 8 cleaned lines of code in 3 files: - paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/HadoopCompliantFileIO.java (107:116) - paimon-filesystems/paimon-s3-impl/src/main/java/org/apache/paimon/s3/HadoopCompliantFileIO.java (107:116) - paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopFileIO.java (123:132) duplicated block id: 14 size: 8 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTableCommittable.java (81:90) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/Committable.java (49:58) duplicated block id: 15 size: 8 cleaned lines of code in 3 files: - paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/InputChangelogFollowUpScanner.java (34:44) - paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousCompactorFollowUpScanner.java (34:44) - paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/DeltaFollowUpScanner.java (34:44) duplicated block id: 16 size: 7 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/ProjectedRowData.java (170:178) - paimon-common/src/main/java/org/apache/paimon/utils/ProjectedRow.java (168:176) duplicated block id: 17 size: 7 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BucketUnawareCompactSource.java (106:114) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MonitorFunction.java (215:224) duplicated block id: 18 size: 7 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java (195:204) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java (219:228) duplicated block id: 19 size: 7 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagActionFactory.java (54:63) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DeleteTagActionFactory.java (52:61) duplicated block id: 20 size: 7 cleaned lines of code in 2 files: - paimon-core/src/main/java/org/apache/paimon/mergetree/ContainsLevels.java (130:138) - paimon-core/src/main/java/org/apache/paimon/mergetree/LookupLevels.java (142:150) duplicated block id: 21 size: 7 cleaned lines of code in 2 files: - paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkScanBuilder.java (71:79) - paimon-spark/paimon-spark-2/src/main/java/org/apache/paimon/spark/SparkDataSourceReader.java (83:91) duplicated block id: 22 size: 6 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcDynamicBucketWriteOperator.java (47:54) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreWriteOperator.java (53:60) duplicated block id: 23 size: 6 cleaned lines of code in 2 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/WrappedManifestCommittableSerializer.java (107:114) - paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittableSerializer.java (98:105) duplicated block id: 24 size: 6 cleaned lines of code in 3 files: - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBListState.java (36:43) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBValueState.java (36:43) - paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBSetState.java (40:47) duplicated block id: 25 size: 6 cleaned lines of code in 2 files: - paimon-core/src/main/java/org/apache/paimon/operation/TagDeletion.java (41:48) - paimon-core/src/main/java/org/apache/paimon/operation/SnapshotDeletion.java (51:58) duplicated block id: 26 size: 6 cleaned lines of code in 2 files: - paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilder.java (103:110) - paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableRead.java (39:46) duplicated block id: 27 size: 6 cleaned lines of code in 2 files: - paimon-core/src/main/java/org/apache/paimon/table/sink/DynamicBucketRowKeyExtractor.java (33:40) - paimon-core/src/main/java/org/apache/paimon/table/sink/UnawareBucketRowKeyExtractor.java (29:36) duplicated block id: 28 size: 6 cleaned lines of code in 2 files: - paimon-format/src/main/java/org/apache/paimon/format/orc/OrcReaderFactory.java (235:242) - paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetReaderFactory.java (341:348)