Skip to content

Commit 7f4bf95

Browse files
committed
fix hbase getscanners in hbase mode
1 parent 398e55a commit 7f4bf95

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
@@ -189,8 +189,10 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
189189
throw new ObTableException("key range columns must be specified when use index");
190190
}
191191
}
192-
if (entityType != ObTableEntityType.HKV &&
193-
getPartId() != null && tableQuery.getIndexName() == null) {
192+
if (getPartId() != null &&
193+
(entityType == ObTableEntityType.HKV || tableQuery.getIndexName() == null)) {
194+
// in table mode, there is no way to fetch index information from ODP, so index name not supported
195+
// in hbase mode, there is no index for hbase table
194196
try {
195197
ObTableParam odpTable = obTableClient.getOdpTableParamWithPartId(tableName, getPartId());
196198
partitionObTables.put(odpTable.getPartId(), new ObPair<>(odpTable.getPartId(), odpTable));

0 commit comments

Comments
 (0)