Skip to content

Commit 678a618

Browse files
committed
add logic id into partition
1 parent ff955e0 commit 678a618

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2019,6 +2019,7 @@ private ObTableParam createTableParam(ObTable obTable, TableEntry tableEntry,
20192019
private ObPair<Long, ObTableParam> getODPTableInternal(TableEntry odpTableEntry, long partId) {
20202020
ObTable obTable = odpTable;
20212021
ObTableParam param = new ObTableParam(obTable);
2022+
param.setPartId(partId);
20222023
long tabletId = partId;
20232024
if (ObGlobal.obVsnMajor() >= 4) {
20242025
long partIdx = odpTableEntry.getPartIdx(partId);
@@ -2318,6 +2319,7 @@ public List<ObPair<Long, ObTableParam>> getOdpTables(String tableName, ObTableQu
23182319
for (Long partId : partIds) {
23192320
ObTable obTable = odpTable;
23202321
ObTableParam param = new ObTableParam(obTable);
2322+
param.setPartId(partId);
23212323
Long tabletId = partId;
23222324
if (ObGlobal.obVsnMajor() >= 4) {
23232325
long partIdx = odpTableEntry.getPartIdx(partId);

0 commit comments

Comments
 (0)