Skip to content

Commit b07ff17

Browse files
committed
fix fts query bugs
1 parent f016062 commit b07ff17

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
@@ -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)