duplicated block id: 1 size: 39 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/utils/FlussRowToFlinkRowConverter.java (119:159) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/FlussRowToFlinkRowConverter.java (112:152) duplicated block id: 2 size: 37 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/enumerator/FlinkSourceEnumerator.java (569:611) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/enumerator/FlinkSourceEnumerator.java (289:332) duplicated block id: 3 size: 17 cleaned lines of code in 2 files: - fluss-common/src/main/java/com/alibaba/fluss/record/DefaultKvRecordBatch.java (103:121) - fluss-common/src/main/java/com/alibaba/fluss/record/DefaultLogRecordBatch.java (157:176) duplicated block id: 4 size: 15 cleaned lines of code in 2 files: - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/SnapshotLocation.java (166:190) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/FsRemoteLogOutputStream.java (63:87) duplicated block id: 5 size: 14 cleaned lines of code in 2 files: - fluss-server/src/main/java/com/alibaba/fluss/server/log/OffsetIndex.java (151:166) - fluss-server/src/main/java/com/alibaba/fluss/server/log/TimeIndex.java (171:186) duplicated block id: 6 size: 13 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/utils/FlussRowToFlinkRowConverter.java (67:81) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/FlinkConversions.java (302:316) duplicated block id: 7 size: 12 cleaned lines of code in 2 files: - fluss-common/src/main/java/com/alibaba/fluss/record/DefaultValueRecordBatch.java (209:223) - fluss-common/src/main/java/com/alibaba/fluss/record/DefaultKvRecordBatch.java (294:308) duplicated block id: 8 size: 12 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/split/HybridSnapshotLogSplit.java (77:90) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/HybridSnapshotLogSplit.java (72:85) duplicated block id: 9 size: 12 cleaned lines of code in 2 files: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/lookup/FlinkLookupFunction.java (68:81) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/lookup/FlinkAsyncLookupFunction.java (71:84) duplicated block id: 10 size: 11 cleaned lines of code in 2 files: - fluss-common/src/main/java/com/alibaba/fluss/security/acl/AccessControlEntry.java (95:107) - fluss-common/src/main/java/com/alibaba/fluss/security/acl/AccessControlEntryFilter.java (112:124) duplicated block id: 11 size: 11 cleaned lines of code in 2 files: - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/SnapshotLocation.java (197:212) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/FsRemoteLogOutputStream.java (101:116) duplicated block id: 12 size: 10 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/metrics/FlinkSourceReaderMetrics.java (112:123) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/metrics/FlinkSourceReaderMetrics.java (106:117) duplicated block id: 13 size: 10 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/metrics/FlinkMetricRegistry.java (85:97) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/metrics/FlinkMetricRegistry.java (101:113) duplicated block id: 14 size: 10 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/split/SourceSplitBase.java (48:59) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SourceSplitBase.java (47:58) duplicated block id: 15 size: 10 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/reader/FlinkRecordsWithSplitIds.java (70:81) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/FlinkRecordsWithSplitIds.java (65:76) duplicated block id: 16 size: 10 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/reader/FlinkRecordsWithSplitIds.java (94:105) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/FlinkRecordsWithSplitIds.java (89:100) duplicated block id: 17 size: 9 cleaned lines of code in 2 files: - fluss-common/src/main/java/com/alibaba/fluss/record/MemoryLogRecordsIndexedBuilder.java (143:154) - fluss-common/src/main/java/com/alibaba/fluss/record/KvRecordBatchBuilder.java (132:143) duplicated block id: 18 size: 9 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/FlussDataTypeToPaimonDataType.java (150:160) - fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/FlussDataTypeToPaimonDataType.java (150:160) duplicated block id: 19 size: 8 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/metrics/FlinkMetricRegistry.java (63:77) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/metrics/FlinkMetricRegistry.java (74:88) duplicated block id: 20 size: 8 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/utils/FlussRowToFlinkRowConverter.java (91:100) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/FlussRowToFlinkRowConverter.java (84:93) duplicated block id: 21 size: 8 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/enumerator/FlinkSourceEnumerator.java (279:288) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/enumerator/FlinkSourceEnumerator.java (255:264) duplicated block id: 22 size: 8 cleaned lines of code in 2 files: - fluss-server/src/main/java/com/alibaba/fluss/server/utils/ServerRpcMessageUtils.java (181:190) - fluss-client/src/main/java/com/alibaba/fluss/client/utils/ClientRpcMessageUtils.java (100:109) duplicated block id: 23 size: 8 cleaned lines of code in 2 files: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/lookup/FlinkLookupFunction.java (171:180) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/lookup/FlinkAsyncLookupFunction.java (218:227) duplicated block id: 24 size: 8 cleaned lines of code in 4 files: - fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufRepeatedBytesField.java (131:140) - fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufRepeatedMessageField.java (87:96) - fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufRepeatedStringField.java (104:113) - fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufRepeatedNumberField.java (162:171) duplicated block id: 25 size: 7 cleaned lines of code in 4 files: - fluss-common/src/main/java/com/alibaba/fluss/utils/json/TableDescriptorJsonSerde.java (146:154) - fluss-common/src/main/java/com/alibaba/fluss/utils/json/DatabaseDescriptorJsonSerde.java (78:86) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TableRegistrationJsonSerde.java (157:165) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/DatabaseRegistrationJsonSerde.java (87:95) duplicated block id: 26 size: 7 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/metrics/FlinkSourceReaderMetrics.java (77:88) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/metrics/FlinkSourceReaderMetrics.java (76:87) duplicated block id: 27 size: 7 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/utils/FlussRowToFlinkRowConverter.java (57:65) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/FlussRowToFlinkRowConverter.java (66:74) duplicated block id: 28 size: 7 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/reader/FlinkRecordsWithSplitIds.java (84:92) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/FlinkRecordsWithSplitIds.java (79:87) duplicated block id: 29 size: 7 cleaned lines of code in 3 files: - fluss-kafka/src/main/java/com/alibaba/fluss/kafka/KafkaCommandDecoder.java (119:127) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/client/NettyClientHandler.java (165:173) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServerHandler.java (179:187) duplicated block id: 30 size: 6 cleaned lines of code in 2 files: - fluss-common/src/main/java/com/alibaba/fluss/row/arrow/writers/ArrowTimestampNtzWriter.java (40:47) - fluss-common/src/main/java/com/alibaba/fluss/row/arrow/writers/ArrowTimestampLtzWriter.java (40:47) duplicated block id: 31 size: 6 cleaned lines of code in 2 files: - fluss-common/src/main/java/com/alibaba/fluss/row/compacted/CompactedRowReader.java (212:219) - fluss-common/src/main/java/com/alibaba/fluss/row/indexed/IndexedRowReader.java (141:148) duplicated block id: 32 size: 6 cleaned lines of code in 2 files: - fluss-common/src/main/java/com/alibaba/fluss/row/compacted/CompactedRowReader.java (221:228) - fluss-common/src/main/java/com/alibaba/fluss/row/indexed/IndexedRowReader.java (150:157) duplicated block id: 33 size: 6 cleaned lines of code in 2 files: - fluss-common/src/main/java/com/alibaba/fluss/row/compacted/CompactedRowWriter.java (252:259) - fluss-common/src/main/java/com/alibaba/fluss/row/indexed/IndexedRowWriter.java (174:181) duplicated block id: 34 size: 6 cleaned lines of code in 2 files: - fluss-common/src/main/java/com/alibaba/fluss/row/compacted/CompactedRowWriter.java (261:268) - fluss-common/src/main/java/com/alibaba/fluss/row/indexed/IndexedRowWriter.java (183:190) duplicated block id: 35 size: 6 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/utils/FlussRowToFlinkRowConverter.java (44:51) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/FlussRowToFlinkRowConverter.java (49:56) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/enumerator/FlinkSourceEnumerator.java (849:856) - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/enumerator/FlinkSourceEnumerator.java (734:741) duplicated block id: 37 size: 6 cleaned lines of code in 3 files: - fluss-server/src/main/java/com/alibaba/fluss/server/authorizer/ZkNodeChangeNotificationWatcher.java (88:95) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/watcher/TableChangeWatcher.java (71:78) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/watcher/TabletServerChangeWatcher.java (59:66) duplicated block id: 38 size: 6 cleaned lines of code in 2 files: - fluss-server/src/main/java/com/alibaba/fluss/server/kv/rowmerger/FirstRowRowMerger.java (51:58) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/rowmerger/VersionedRowMerger.java (72:79) duplicated block id: 39 size: 6 cleaned lines of code in 2 files: - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/statemachine/TableBucketStateMachine.java (51:58) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/statemachine/ReplicaStateMachine.java (59:66) duplicated block id: 40 size: 6 cleaned lines of code in 2 files: - fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufRepeatedBytesField.java (85:92) - fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufRepeatedStringField.java (94:101)