Skip to content

Commit fee629c

Browse files
committed
add suspect ip first and refresh tablet location after
1 parent 9cccdd2 commit fee629c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1182,14 +1182,14 @@ public Row transformToRow(String tableName, Object[] rowkey) throws Exception {
11821182
}
11831183

11841184
public void dealWithRpcTimeoutForSingleTablet(ObServerAddr addr, String tableName, long tabletId) throws Exception {
1185-
tableRoute.refreshPartitionLocation(tableName, tabletId, null);
11861185
RouteTableRefresher.SuspectObServer suspectAddr = new RouteTableRefresher.SuspectObServer(addr);
11871186
RouteTableRefresher.addIntoSuspectIPs(suspectAddr);
1187+
tableRoute.refreshPartitionLocation(tableName, tabletId, null);
11881188
}
11891189
public void dealWithRpcTimeoutForBatchTablet(ObServerAddr addr, String tableName) throws Exception {
1190-
tableRoute.refreshTabletLocationBatch(tableName);
11911190
RouteTableRefresher.SuspectObServer suspectAddr = new RouteTableRefresher.SuspectObServer(addr);
11921191
RouteTableRefresher.addIntoSuspectIPs(suspectAddr);
1192+
tableRoute.refreshTabletLocationBatch(tableName);
11931193
}
11941194

11951195
/**

0 commit comments

Comments
 (0)