Skip to content

Commit fa63839

Browse files
committed
fix
1 parent ebf119c commit fa63839

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

src/main/java/com/alipay/oceanbase/rpc/location/LocationUtil.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1206,9 +1206,6 @@ private static ObPartitionEntry getPartitionLocationFromResultSetByTablet(TableE
12061206
ObPartitionLocationInfo partitionLocationInfo = partitionEntry.getPartitionInfo(tabletId);
12071207

12081208
while (rs.next()) {
1209-
if (partitionLocationInfo.initialized.get()) {
1210-
continue;
1211-
}
12121209
ReplicaLocation replica = buildReplicaLocation(rs);
12131210
long partitionId = (ObGlobal.obVsnMajor() >= 4) ? rs.getLong("tablet_id") : rs
12141211
.getLong("partition_id");

0 commit comments

Comments
 (0)