Skip to content

Commit 330d79c

Browse files
committed
do not calculate partition_id in ODP mode when using index query
1 parent 4d364e5 commit 330d79c

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -167,8 +167,10 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
167167
&& !tableQuery.getIndexName().equalsIgnoreCase("primary")) {
168168
throw new ObTableException("key range columns must be specified when use index");
169169
}
170-
}
171-
if (getPartId() == null) {
170+
} else if (tableQuery.getIndexName() != null) {
171+
this.partitionObTables.put(0L, new ObPair<Long, ObTableParam>(0L, new ObTableParam(
172+
obTableClient.getOdpTable())));
173+
} else if (getPartId() == null) {
172174
initPartitions();
173175
} else {
174176
ObPair<Long, ObTableParam> odpTable = obTableClient.getODPTableWithPartId(

0 commit comments

Comments
 (0)