diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java b/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java index 4e1cc84e0dd..657ded55e7f 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java @@ -2366,8 +2366,12 @@ public class ElasticSearchClient implements SearchClient { .createParser( EsUtils.esXContentRegistry, LoggingDeprecationHandler.INSTANCE, queryFilter); QueryBuilder filter = SearchSourceBuilder.fromXContent(filterParser).query(); - BoolQueryBuilder newQuery = - QueryBuilders.boolQuery().must(searchSourceBuilder.query()).filter(filter); + BoolQueryBuilder newQuery; + if (!nullOrEmpty(searchSourceBuilder.query())) { + newQuery = QueryBuilders.boolQuery().must(searchSourceBuilder.query()).filter(filter); + } else { + newQuery = QueryBuilders.boolQuery().filter(filter); + } searchSourceBuilder.query(newQuery); } catch (Exception ex) { LOG.warn("Error parsing query_filter from query parameters, ignoring filter", ex); diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/search/opensearch/OpenSearchClient.java b/openmetadata-service/src/main/java/org/openmetadata/service/search/opensearch/OpenSearchClient.java index c40773ab4c6..b3fb3931896 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/search/opensearch/OpenSearchClient.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/search/opensearch/OpenSearchClient.java @@ -2457,8 +2457,12 @@ public class OpenSearchClient implements SearchClient { .createParser( OsUtils.osXContentRegistry, LoggingDeprecationHandler.INSTANCE, queryFilter); QueryBuilder filter = SearchSourceBuilder.fromXContent(filterParser).query(); - BoolQueryBuilder newQuery = - QueryBuilders.boolQuery().must(searchSourceBuilder.query()).filter(filter); + BoolQueryBuilder newQuery; + if (!nullOrEmpty(searchSourceBuilder.query())) { + newQuery = QueryBuilders.boolQuery().must(searchSourceBuilder.query()).filter(filter); + } else { + newQuery = QueryBuilders.boolQuery().filter(filter); + } searchSourceBuilder.query(newQuery); } catch (Exception ex) { LOG.warn("Error parsing query_filter from query parameters, ignoring filter", ex);