Skip to content

Commit 235c3a5

Browse files
remove unused condition
1 parent 1451f5a commit 235c3a5

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

fluss-server/src/main/java/com/alibaba/fluss/server/replica/ReplicaManager.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1092,9 +1092,7 @@ else if (canFetchFromRemoteLog(replica, fetchOffset)) {
10921092
if (tb.getPartitionId() != null) {
10931093
PartitionMetadata partitionMetadata =
10941094
metadataCache.getPartitionMetadata(replica.getPhysicalTablePath());
1095-
if (partitionMetadata == null
1096-
|| partitionMetadata.getPartitionId()
1097-
== PartitionMetadata.DELETED_PARTITION_ID) {
1095+
if (partitionMetadata == null) {
10981096
return new FetchLogResultForBucket(
10991097
tb,
11001098
ApiError.fromThrowable(

0 commit comments

Comments
 (0)