7 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/utils/json/DataTypeJsonSerde.java (98:104, 3%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/utils/FlussRowToFlinkRowConverter.java (121:127, 8%) 7 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/row/indexed/IndexedRow.java (244:250, 2%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/utils/FlussRowToFlinkRowConverter.java (121:127, 8%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/record/IndexedLogRecord.java (85:92, 6%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/DataType.java (146:152, 13%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/record/FileLogInputStream.java (232:238, 4%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/Schema.java (431:437, 2%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/TableBucketReplica.java (40:46, 25%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/PhysicalTablePath.java (103:109, 10%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/ArrayType.java (80:86, 15%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/record/DefaultKvRecordBatch.java (207:213, 3%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/RowType.java (140:146, 4%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/fs/FsPathAndFileName.java (49:55, 18%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/record/DefaultValueRecordBatch.java (120:126, 3%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/BinaryType.java (101:107, 11%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/row/BinarySection.java (103:109, 10%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/SchemaInfo.java (51:57, 20%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/DecimalType.java (108:114, 10%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/DataField.java (83:89, 10%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/record/TimestampAndOffset.java (49:55, 23%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/TableBucket.java (77:83, 12%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/record/DefaultLogRecordBatch.java (256:263, 2%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/PartitionInfo.java (60:66, 20%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/TablePartition.java (57:63, 20%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/TablePath.java (93:99, 7%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/LocalZonedTimestampType.java (108:114, 11%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/remote/RemoteLogSegment.java (113:119, 4%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/MapType.java (90:96, 13%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/TableDescriptor.java (295:301, 1%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/record/DefaultKvRecord.java (81:87, 6%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/CharType.java (100:106, 11%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/TimestampType.java (101:107, 12%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/record/FileLogRecords.java (499:505, 2%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/TableDescriptor.java (436:442, 1%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/Schema.java (156:162, 2%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/Schema.java (378:384, 2%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/metadata/PartitionSpec.java (53:59, 27%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%) 6 duplicated lines in: - fluss-common/src/main/java/com/alibaba/fluss/types/TimeType.java (94:100, 12%) - fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/event/TableBucketsUnsubscribedEvent.java (44:50, 25%)