Skip to content

Commit 8d8e8d9

Browse files
committed
fix global index route wrong when need partial route refresh
1 parent 142249c commit 8d8e8d9

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -145,6 +145,11 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger,
145145
if (failedServerList != null) {
146146
route.setBlackList(failedServerList);
147147
}
148+
if (ObGlobal.obVsnMajor() >= 4) {
149+
TableEntry tableEntry = client.getOrRefreshTableEntry(indexTableName, false, false, false);
150+
client.refreshTableLocationByTabletId(tableEntry, indexTableName, client.getTabletIdByPartId(tableEntry, partIdWithIndex.getLeft()));
151+
}
152+
148153
subObTable = client
149154
.getTableWithPartId(indexTableName, partIdWithIndex.getLeft(),
150155
needRefreshTableEntry, client.isTableEntryRefreshIntervalWait(),

0 commit comments

Comments
 (0)