Skip to content

Commit fa6df3b

Browse files
committed
fix fts query bugs
1 parent 78bd02e commit fa6df3b

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
@@ -117,9 +117,9 @@ protected ObTableQueryAsyncResult referToNewPartition(ObPair<Long, ObTableParam>
117117
queryRequest.setPartitionId(obTableParam.getPartitionId());
118118
queryRequest.setTableId(obTableParam.getTableId());
119119
if (operationTimeout > 0) {
120-
queryRequest.setTimeout(operationTimeout);
120+
asyncRequest.setTimeout(operationTimeout);
121121
} else {
122-
queryRequest.setTimeout(obTableParam.getObTable().getObTableOperationTimeout());
122+
asyncRequest.setTimeout(obTableParam.getObTable().getObTableOperationTimeout());
123123
}
124124

125125
// 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
@@ -163,6 +163,11 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
163163
// Currently, fulltext query only support scan all partitions
164164
tableQuery.getKeyRanges().clear();
165165
tableQuery.addKeyRange(ObNewRange.getWholeRange());
166+
if (tableQuery.getIndexName() == null || tableQuery.getIndexName().isEmpty()
167+
|| tableQuery.getIndexName().equalsIgnoreCase("primary")) {
168+
throw new IllegalArgumentException(
169+
"use fulltext search but specified index name is not fulltext index");
170+
}
166171
}
167172

168173
// init partitionObTables

0 commit comments

Comments
 (0)