Skip to content

Commit bfa9947

Browse files
committed
fix fts query bugs
1 parent 9de0ecd commit bfa9947

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

src/main/java/com/alipay/oceanbase/rpc/stream/ObTableClientQueryAsyncStreamResult.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -119,9 +119,9 @@ protected ObTableQueryAsyncResult referToNewPartition(ObPair<Long, ObTableParam>
119119
queryRequest.setPartitionId(obTableParam.getPartitionId());
120120
queryRequest.setTableId(obTableParam.getTableId());
121121
if (operationTimeout > 0) {
122-
queryRequest.setTimeout(operationTimeout);
122+
asyncRequest.setTimeout(operationTimeout);
123123
} else {
124-
queryRequest.setTimeout(obTableParam.getObTable().getObTableOperationTimeout());
124+
asyncRequest.setTimeout(obTableParam.getObTable().getObTableOperationTimeout());
125125
}
126126

127127
// refresh async query request

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -164,6 +164,11 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
164164
// Currently, fulltext query only support scan all partitions
165165
tableQuery.getKeyRanges().clear();
166166
tableQuery.addKeyRange(ObNewRange.getWholeRange());
167+
if (tableQuery.getIndexName() == null || tableQuery.getIndexName().isEmpty()
168+
|| tableQuery.getIndexName().equalsIgnoreCase("primary")) {
169+
throw new IllegalArgumentException(
170+
"use fulltext search but specified index name is not fulltext index");
171+
}
167172
}
168173

169174
// init partitionObTables

0 commit comments

Comments
 (0)