Skip to content

Commit f26a4f2

Browse files
committed
refine
1 parent 66ad49d commit f26a4f2

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1897,9 +1897,7 @@ private ObPartitionLocationInfo getOrRefreshPartitionInfo(TableEntry tableEntry,
18971897
ObPartitionLocationInfo obPartitionLocationInfo = tableEntry.getPartitionEntry()
18981898
.getPartitionInfo(tabletId);
18991899
if (!obPartitionLocationInfo.initialized.get()) {
1900-
if (ObGlobal.obVsnMajor() >= 4) {
1901-
tableEntry = refreshTableLocationByTabletId(tableEntry, tableName, tabletId);
1902-
}
1900+
tableEntry = refreshTableLocationByTabletId(tableEntry, tableName, tabletId);
19031901
obPartitionLocationInfo = tableEntry.getPartitionEntry().getPartitionInfo(tabletId);
19041902
obPartitionLocationInfo.initializationLatch.await();
19051903
}

0 commit comments

Comments
 (0)