Skip to content

Commit 64926a4

Browse files
committed
fix lsop refresh location
1 parent 4c630ee commit 64926a4

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import com.alipay.oceanbase.rpc.checkandmutate.CheckAndInsUp;
2222
import com.alipay.oceanbase.rpc.exception.*;
2323
import com.alipay.oceanbase.rpc.location.model.ObServerRoute;
24+
import com.alipay.oceanbase.rpc.location.model.TableEntry;
2425
import com.alipay.oceanbase.rpc.location.model.partition.ObPair;
2526
import com.alipay.oceanbase.rpc.mutation.*;
2627
import com.alipay.oceanbase.rpc.mutation.result.MutationResult;
@@ -473,6 +474,9 @@ public void partitionExecute(ObTableSingleOpResult[] results,
473474
if (failedServerList != null) {
474475
route.setBlackList(failedServerList);
475476
}
477+
TableEntry entry = obTableClient.getOrRefreshTableEntry(tableName, false,
478+
false, false);
479+
obTableClient.refreshTableLocationByTabletId(entry, tableName, obTableClient.getTabletIdByPartId(entry, originPartId));
476480
subObTable = obTableClient.getTableWithPartId(tableName, originPartId, needRefreshTableEntry,
477481
obTableClient.isTableEntryRefreshIntervalWait(), false, route).
478482
getRight().getObTable();

0 commit comments

Comments
 (0)