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