Skip to content

Commit 6b249bf

Browse files
committed
fix
1 parent 4e1c005 commit 6b249bf

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
@@ -1214,9 +1214,6 @@ private static ObPartitionEntry getPartitionLocationFromResultSetByTablet(TableE
12141214
ObPartitionLocationInfo partitionLocationInfo = partitionEntry.getPartitionInfo(tabletId);
12151215

12161216
while (rs.next()) {
1217-
if (partitionLocationInfo.initialized.get()) {
1218-
continue;
1219-
}
12201217
ReplicaLocation replica = buildReplicaLocation(rs);
12211218
long partitionId = (ObGlobal.obVsnMajor() >= 4) ? rs.getLong("tablet_id") : rs
12221219
.getLong("partition_id");

0 commit comments

Comments
 (0)