Skip to content

Commit 091f741

Browse files
committed
fix lsop -5200 with table_group
1 parent ad01c8b commit 091f741

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -515,12 +515,12 @@ public void partitionExecute(ObTableSingleOpResult[] results,
515515
if (failedServerList != null) {
516516
route.setBlackList(failedServerList);
517517
}
518-
TableEntry entry = obTableClient.getOrRefreshTableEntry(tableName, false,
518+
TableEntry entry = obTableClient.getOrRefreshTableEntry(realTableName, false,
519519
false, false);
520520
if (ObGlobal.obVsnMajor() >= 4) {
521-
obTableClient.refreshTableLocationByTabletId(entry, tableName, obTableClient.getTabletIdByPartId(entry, originPartId));
521+
obTableClient.refreshTableLocationByTabletId(entry, realTableName, obTableClient.getTabletIdByPartId(entry, originPartId));
522522
}
523-
subObTable = obTableClient.getTableWithPartId(tableName, originPartId, needRefreshTableEntry,
523+
subObTable = obTableClient.getTableWithPartId(realTableName, originPartId, needRefreshTableEntry,
524524
obTableClient.isTableEntryRefreshIntervalWait(), false, route).
525525
getRight().getObTable();
526526
}

0 commit comments

Comments
 (0)