Skip to content

Commit 73569e8

Browse files
committed
fix getLs nullptr
1 parent 9e00705 commit 73569e8

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
@@ -2318,12 +2318,8 @@ public List<ObPair<Long, ObTableParam>> getTables(String tableName, ObTableQuery
23182318

23192319
ObTableParam param = new ObTableParam(obTable);
23202320
param.setPartId(partId);
2321-
if (ObGlobal.obVsnMajor() >= 4) {
2322-
long partIdx = tableEntry.getPartIdx(partId);
2323-
partId = tableEntry.isPartitionTable() ? tableEntry.getPartitionInfo()
2324-
.getPartTabletIdMap().get(partIdx) : partId;
2325-
param.setLsId(tableEntry.getPartitionEntry().getLsId(partId));
2326-
}
2321+
partId = getTabletIdByPartId(tableEntry, partId);
2322+
param.setLsId(tableEntry.getPartitionEntry().getPartitionInfo(partId).getTabletLsId());
23272323

23282324
param.setTableId(tableEntry.getTableId());
23292325
// real partition(tablet) id

0 commit comments

Comments
 (0)