Issue #528: Add ignore_unavailable to prevent no such index exception

smclab · Jul 26, 2023 · 82b9075 · 82b9075
1 parent b4f3c31
commit 82b9075
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/core/app/datasource/src/main/java/io/openk9/datasource/service/DataIndexService.java b/core/app/datasource/src/main/java/io/openk9/datasource/service/DataIndexService.java
@@ -33,13 +33,15 @@
 import io.openk9.datasource.service.util.Tuple2;
 import io.smallrye.mutiny.Uni;
 import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
+import org.elasticsearch.action.support.IndicesOptions;
 import org.elasticsearch.action.support.master.AcknowledgedResponse;
 import org.elasticsearch.client.RequestOptions;
 import org.elasticsearch.client.RestHighLevelClient;
 
 import javax.enterprise.context.ApplicationScoped;
 import javax.inject.Inject;
 import java.io.IOException;
+import java.util.Map;
 import java.util.Set;
 
 @ApplicationScoped
@@ -155,8 +157,18 @@ public Uni<DataIndex> deleteById(long entityId) {
 			.onItem()
 			.transformToUni(dataIndex -> Uni.createFrom()
 				.<AcknowledgedResponse>emitter(emitter -> {
+
 					DeleteIndexRequest deleteIndexRequest =
 						new DeleteIndexRequest(dataIndex.getName());
+
+					deleteIndexRequest
+						.indicesOptions(
+							IndicesOptions.fromMap(
+								Map.of("ignore_unavailable", true),
+								deleteIndexRequest.indicesOptions()
+							)
+						);
+
 					try {
 						AcknowledgedResponse delete = client.indices().delete(
 							deleteIndexRequest,