diff --git a/vector-stores/spring-ai-opensearch-store/src/main/java/org/springframework/ai/vectorstore/opensearch/OpenSearchVectorStore.java b/vector-stores/spring-ai-opensearch-store/src/main/java/org/springframework/ai/vectorstore/opensearch/OpenSearchVectorStore.java index f0d8ab217..13a3f59cf 100644 --- a/vector-stores/spring-ai-opensearch-store/src/main/java/org/springframework/ai/vectorstore/opensearch/OpenSearchVectorStore.java +++ b/vector-stores/spring-ai-opensearch-store/src/main/java/org/springframework/ai/vectorstore/opensearch/OpenSearchVectorStore.java @@ -222,6 +222,9 @@ public class OpenSearchVectorStore extends AbstractObservationVectorStore implem for (String id : idList) { bulkRequestBuilder.operations(op -> op.delete(idx -> idx.index(this.index).id(id))); } + if (bulkRequest(bulkRequestBuilder.build()).errors()) { + throw new IllegalStateException("Delete operation failed"); + } } private BulkResponse bulkRequest(BulkRequest bulkRequest) {