diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java index 11e568301756ce5096450ae8c420f852180714b9..bc8d633ac9be3a39336ea79a634709e1f34c2940 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java @@ -312,8 +312,9 @@ public class IndicesServiceImpl implements IndicesService { try { List<String> kinds = new ArrayList<>(); kinds.add(kind); - if(getKindWithMajorVersion(kind) != null) { - kinds.add(getKindWithMajorVersion(kind)); + String kindWithMajorVersion = getKindWithMajorVersion(kind); + if(elasticIndexNameResolver.isIndexAliasSupported(kindWithMajorVersion)) { + kinds.add(kindWithMajorVersion); } for (String kd : kinds) { index = elasticIndexNameResolver.getIndexNameFromKind(kd); diff --git a/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndicesServiceTest.java b/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndicesServiceTest.java index 8e975d58bebf7b2fdde4bb8fbb9a0374993a9b4d..7f22b619a9364b308791473adbae5324a0687d9a 100644 --- a/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndicesServiceTest.java +++ b/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndicesServiceTest.java @@ -102,6 +102,7 @@ public class IndicesServiceTest { when(elasticIndexNameResolver.getKindFromIndexName(any())).thenReturn(kind); when(elasticIndexNameResolver.getIndexNameFromKind(any())).thenReturn(index); when(elasticIndexNameResolver.getIndexAliasFromKind(any())).thenReturn("a12345678"); + when(elasticIndexNameResolver.isIndexAliasSupported(any())).thenReturn(true); when(restHighLevelClient.indices()).thenReturn(indicesClient); when(indicesClient.create(any(CreateIndexRequest.class), any(RequestOptions.class))).thenReturn(indexResponse); when(indicesClient.updateAliases(any(IndicesAliasesRequest.class), any(RequestOptions.class))).thenReturn(acknowledgedResponse);