diff --git a/openmetadata-service/src/test/java/org/openmetadata/service/resources/apps/AppsResourceTest.java b/openmetadata-service/src/test/java/org/openmetadata/service/resources/apps/AppsResourceTest.java index 52e6990845e..0a53d79c9d1 100644 --- a/openmetadata-service/src/test/java/org/openmetadata/service/resources/apps/AppsResourceTest.java +++ b/openmetadata-service/src/test/java/org/openmetadata/service/resources/apps/AppsResourceTest.java @@ -6,6 +6,7 @@ import static javax.ws.rs.core.Response.Status.NOT_FOUND; import static javax.ws.rs.core.Response.Status.OK; import static org.openmetadata.common.utils.CommonUtil.listOf; import static org.openmetadata.schema.type.ColumnDataType.INT; +import static org.openmetadata.service.Entity.getSearchRepository; import static org.openmetadata.service.util.TestUtils.ADMIN_AUTH_HEADERS; import static org.openmetadata.service.util.TestUtils.assertEventually; import static org.openmetadata.service.util.TestUtils.assertResponseContains; @@ -316,7 +317,13 @@ public class AppsResourceTest extends EntityResourceTest { // ------------------------------------------------- RestClient searchClient = getSearchClient(); es.org.elasticsearch.client.Response response; - Request request = new Request("GET", "di-data-assets-*/_search"); + String clusterAlias = getSearchRepository().getClusterAlias(); + String endpointSuffix = "di-data-assets-*"; + String endpoint = + !(clusterAlias == null || clusterAlias.isEmpty()) + ? String.format("%s-%s", clusterAlias, endpointSuffix) + : endpointSuffix; + Request request = new Request("GET", String.format("%s/_search", endpoint)); String payload = String.format( "{\"query\":{\"bool\":{\"must\":{\"term\":{\"fullyQualifiedName\":\"%s\"}}}}}",