Skip to content

Commit 1f2a8f4

Browse files
committed
fix lsop refresh location
1 parent 14cf774 commit 1f2a8f4

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

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

Lines changed: 5 additions & 1 deletion
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;
@@ -474,7 +475,10 @@ public void partitionExecute(ObTableSingleOpResult[] results,
474475
if (failedServerList != null) {
475476
route.setBlackList(failedServerList);
476477
}
477-
subObTable = obTableClient.getTableWithPartId(realTableName, originPartId, needRefreshTableEntry,
478+
TableEntry entry = obTableClient.getOrRefreshTableEntry(tableName, false,
479+
false, false);
480+
obTableClient.refreshTableLocationByTabletId(entry, tableName, obTableClient.getTabletIdByPartId(entry, originPartId));
481+
subObTable = obTableClient.getTableWithPartId(tableName, originPartId, needRefreshTableEntry,
478482
obTableClient.isTableEntryRefreshIntervalWait(), false, route).
479483
getRight().getObTable();
480484
}

0 commit comments

Comments
 (0)