Skip to content

Commit 8beb8de

Browse files
committed
fix getLs nullptr
1 parent b2383d9 commit 8beb8de

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

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

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2326,12 +2326,8 @@ private List<ObPair<Long, ObTableParam>> getTables(String tableName, ObTableQuer
23262326

23272327
ObTableParam param = new ObTableParam(obTable);
23282328
param.setPartId(partId);
2329-
if (ObGlobal.obVsnMajor() >= 4) {
2330-
long partIdx = tableEntry.getPartIdx(partId);
2331-
partId = tableEntry.isPartitionTable() ? tableEntry.getPartitionInfo()
2332-
.getPartTabletIdMap().get(partIdx) : partId;
2333-
param.setLsId(tableEntry.getPartitionEntry().getLsId(partId));
2334-
}
2329+
partId = getTabletIdByPartId(tableEntry, partId);
2330+
param.setLsId(tableEntry.getPartitionEntry().getPartitionInfo(partId).getTabletLsId());
23352331

23362332
param.setTableId(tableEntry.getTableId());
23372333
// real partition(tablet) id

0 commit comments

Comments
 (0)