From 1fee0827e46f636cd29c10c77825190ec198ff6e Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 6 Feb 2025 14:10:02 -0500 Subject: [PATCH] Fixing ElasticsearchVectorStoreIT test failures Signed-off-by: Soby Chacko --- .../ai/vectorstore/elasticsearch/ElasticsearchVectorStore.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/vector-stores/spring-ai-elasticsearch-store/src/main/java/org/springframework/ai/vectorstore/elasticsearch/ElasticsearchVectorStore.java b/vector-stores/spring-ai-elasticsearch-store/src/main/java/org/springframework/ai/vectorstore/elasticsearch/ElasticsearchVectorStore.java index ee19c25dc..01366c5a7 100644 --- a/vector-stores/spring-ai-elasticsearch-store/src/main/java/org/springframework/ai/vectorstore/elasticsearch/ElasticsearchVectorStore.java +++ b/vector-stores/spring-ai-elasticsearch-store/src/main/java/org/springframework/ai/vectorstore/elasticsearch/ElasticsearchVectorStore.java @@ -219,6 +219,9 @@ public class ElasticsearchVectorStore extends AbstractObservationVectorStore imp for (String id : idList) { bulkRequestBuilder.operations(op -> op.delete(idx -> idx.index(this.options.getIndexName()).id(id))); } + if (bulkRequest(bulkRequestBuilder.build()).errors()) { + throw new IllegalStateException("Delete operation failed"); + } } @Override