diff --git a/common/src/main/java/com/tencent/supersonic/common/service/impl/EmbeddingServiceImpl.java b/common/src/main/java/com/tencent/supersonic/common/service/impl/EmbeddingServiceImpl.java index df71dc11e..a8a0f590d 100644 --- a/common/src/main/java/com/tencent/supersonic/common/service/impl/EmbeddingServiceImpl.java +++ b/common/src/main/java/com/tencent/supersonic/common/service/impl/EmbeddingServiceImpl.java @@ -59,6 +59,7 @@ public class EmbeddingServiceImpl implements EmbeddingService { continue; } embeddingStore.add(embedding, query); + cache.put(TextSegmentConvert.getQueryId(query), true); } catch (Exception e) { log.error("embeddingModel embed error question: {}, embeddingStore: {}", question, embeddingStore.getClass().getSimpleName(), e); @@ -85,7 +86,6 @@ public class EmbeddingServiceImpl implements EmbeddingService { EmbeddingSearchResult result = embeddingStore.search(request); List> relevant = result.matches(); boolean exists = CollectionUtils.isNotEmpty(relevant); - cache.put(queryId, exists); return exists; }