8 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:58, 42%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/PartitionAssignment.java (46:55, 40%) 8 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:65, 28%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/PartitionAssignment.java (46:55, 40%) 8 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:60, 25%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/PartitionAssignment.java (46:55, 40%) 7 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (48:57, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/TimestampOffset.java (42:51, 24%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/NewTabletServerEvent.java (36:42, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/entity/FetchData.java (82:88, 11%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java (555:561, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java (615:621, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/FetchParams.java (177:183, 5%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshotHandle.java (103:109, 12%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/NewTabletServerEvent.java (36:42, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (391:397, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvSnapshotHandle.java (139:145, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/DropPartitionEvent.java (48:54, 16%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (442:448, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/LogSegmentFiles.java (72:78, 12%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (149:155, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/FetchParams.java (177:183, 5%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (217:223, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/RemoteLogManifest.java (119:125, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetMetadata.java (128:134, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TabletServerRegistration.java (46:52, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (68:74, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (442:448, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshot.java (175:181, 7%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/TimestampOffset.java (45:51, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedTableBucketKey.java (41:47, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (391:397, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (328:334, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CreateTableEvent.java (47:53, 18%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/entity/FetchData.java (82:88, 11%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvFileHandleAndLocalPath.java (62:68, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/OffsetPosition.java (50:56, 18%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (68:74, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/DropPartitionEvent.java (48:54, 16%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/RemoteLogManifestHandle.java (47:53, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (149:155, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/PartitionAssignment.java (46:52, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/BucketAssignment.java (44:50, 27%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (68:74, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvFileHandle.java (49:55, 14%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/DeadTabletServerEvent.java (34:40, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherManager.java (257:263, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherManager.java (285:291, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetSnapshot.java (41:47, 13%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetSnapshot.java (41:47, 13%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetSnapshot.java (41:47, 13%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/SharedKvFileRegistryKey.java (51:57, 26%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (328:334, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetMetadata.java (128:134, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CreatePartitionEvent.java (67:73, 10%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/DeadTabletServerEvent.java (34:40, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/DeadTabletServerEvent.java (34:40, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/BucketAssignment.java (44:50, 27%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (68:74, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/entity/CommitRemoteLogManifestData.java (101:107, 9%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CreateTableEvent.java (47:53, 18%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/LogTieringTask.java (488:494, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/LogTieringTask.java (488:494, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (149:155, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherManager.java (285:291, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherManager.java (257:263, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/LogTieringTask.java (488:494, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/OffsetPosition.java (50:56, 18%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/RemoteLogManifest.java (119:125, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/LogSegmentFiles.java (72:78, 12%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CreateTableEvent.java (47:53, 18%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/LogSegmentFiles.java (72:78, 12%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/LogSegmentFiles.java (72:78, 12%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvFileHandleAndLocalPath.java (62:68, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TableRegistration.java (134:141, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java (615:621, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LoadedLogOffsets.java (43:49, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvFileHandleAndLocalPath.java (62:68, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/LeaderAndIsr.java (108:114, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java (555:561, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/LeaderAndIsr.java (108:114, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (149:155, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/LeaderAndIsr.java (108:114, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TabletServerRegistration.java (46:52, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TableAssignment.java (53:59, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TableRegistration.java (134:141, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/BucketAssignment.java (44:50, 27%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LoadedLogOffsets.java (43:49, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TableRegistration.java (134:141, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (391:397, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvSnapshotHandle.java (139:145, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CreatePartitionEvent.java (67:73, 10%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LoadedLogOffsets.java (43:49, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/RemoteLogManifestHandle.java (47:53, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshot.java (175:181, 7%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (442:448, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/RemoteLogManifest.java (119:125, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (217:223, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshot.java (175:181, 7%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/entity/CommitRemoteLogManifestData.java (101:107, 9%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/RemoteLogManifestHandle.java (47:53, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CreatePartitionEvent.java (67:73, 10%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java (555:561, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedTableBucketKey.java (41:47, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/RemoteLogManifestHandle.java (47:53, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/FetchParams.java (177:183, 5%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TableAssignment.java (53:59, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetMetadata.java (128:134, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/SharedKvFileRegistryKey.java (51:57, 26%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TabletServerRegistration.java (46:52, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherManager.java (285:291, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherManager.java (257:263, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvFileHandle.java (49:55, 14%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/OffsetPosition.java (50:56, 18%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (217:223, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/RemoteLogManifest.java (119:125, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java (615:621, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java (555:561, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedTableBucketKey.java (41:47, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/SharedKvFileRegistryKey.java (51:57, 26%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/LogTieringTask.java (488:494, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/BucketAssignment.java (44:50, 27%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedTableBucketKey.java (41:47, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvFileHandle.java (49:55, 14%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java (217:223, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (328:334, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/entity/CommitRemoteLogManifestData.java (101:107, 9%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TableAssignment.java (53:59, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherManager.java (257:263, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherManager.java (285:291, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/TimestampOffset.java (45:51, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/entity/CommitRemoteLogManifestData.java (101:107, 9%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TabletServerRegistration.java (46:52, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CreateTableEvent.java (47:53, 18%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TableAssignment.java (53:59, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/NewTabletServerEvent.java (36:42, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvSnapshotHandle.java (139:145, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/entity/FetchData.java (82:88, 11%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetMetadata.java (128:134, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/SharedKvFileRegistryKey.java (51:57, 26%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvSnapshotHandle.java (139:145, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetSnapshot.java (41:47, 13%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/DeadTabletServerEvent.java (34:40, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/NewTabletServerEvent.java (36:42, 30%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/FetchParams.java (177:183, 5%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CreatePartitionEvent.java (67:73, 10%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshotHandle.java (103:109, 12%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/DropPartitionEvent.java (48:54, 16%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshot.java (175:181, 7%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvFileHandleAndLocalPath.java (62:68, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/TableRegistration.java (134:141, 4%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (391:397, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java (615:621, 1%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/zk/data/LeaderAndIsr.java (108:114, 8%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/entity/FetchData.java (82:88, 11%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (442:448, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/DropPartitionEvent.java (48:54, 16%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshotHandle.java (103:109, 12%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite/KvPreWriteBuffer.java (328:334, 3%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/LoadedLogOffsets.java (43:49, 17%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java (51:57, 18%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshotHandle.java (103:109, 12%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java (79:85, 14%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/TimestampOffset.java (45:51, 20%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java (49:55, 31%) - fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/KvFileHandle.java (49:55, 14%) 6 duplicated lines in: - fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java (56:62, 21%) - fluss-server/src/main/java/com/alibaba/fluss/server/log/OffsetPosition.java (50:56, 18%)