8 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SnapshotSplit.java (56:65, 18%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:65, 28%) 8 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SnapshotSplit.java (56:65, 18%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:60, 25%) 8 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SnapshotSplit.java (56:65, 18%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:58, 42%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SourceSplitBase.java (103:109, 10%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SourceSplitBase.java (103:109, 10%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/RecordAndPos.java (64:70, 18%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/RecordAndPos.java (64:70, 18%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/event/PartitionBucketsUnsubscribedEvent.java (44:50, 28%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/state/SourceEnumeratorState.java (49:55, 19%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/event/PartitionBucketsUnsubscribedEvent.java (44:50, 28%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/state/SourceEnumeratorState.java (49:55, 19%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/state/SourceEnumeratorState.java (49:55, 19%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SourceSplitBase.java (103:109, 10%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SnapshotSplit.java (56:62, 13%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/event/PartitionBucketsUnsubscribedEvent.java (44:50, 28%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/RecordAndPos.java (64:70, 18%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/RecordAndPos.java (64:70, 18%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/state/SourceEnumeratorState.java (49:55, 19%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/event/PartitionBucketsUnsubscribedEvent.java (44:50, 28%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) 6 duplicated lines in: - fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SourceSplitBase.java (103:109, 10%) - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%)