mirror of
https://github.com/open-metadata/OpenMetadata.git
synced 2025-09-03 14:13:06 +00:00
Minor : Fix exception in search due to exception in database.displayName and databaseSchema.aggregation (#18290)
This commit is contained in:
parent
6a4c685849
commit
9dbe7e3376
@ -1297,6 +1297,23 @@ public class ElasticSearchClient implements SearchClient {
|
|||||||
buildSearchQueryBuilder(query, SearchIndex.getAllFields());
|
buildSearchQueryBuilder(query, SearchIndex.getAllFields());
|
||||||
FunctionScoreQueryBuilder queryBuilder = boostScore(queryStringBuilder);
|
FunctionScoreQueryBuilder queryBuilder = boostScore(queryStringBuilder);
|
||||||
SearchSourceBuilder searchSourceBuilder = searchBuilder(queryBuilder, null, from, size);
|
SearchSourceBuilder searchSourceBuilder = searchBuilder(queryBuilder, null, from, size);
|
||||||
|
searchSourceBuilder.aggregation(
|
||||||
|
AggregationBuilders.terms("database.name.keyword")
|
||||||
|
.field("database.name.keyword")
|
||||||
|
.size(MAX_AGGREGATE_SIZE));
|
||||||
|
searchSourceBuilder.aggregation(
|
||||||
|
AggregationBuilders.terms("databaseSchema.name.keyword")
|
||||||
|
.field("databaseSchema.name.keyword")
|
||||||
|
.size(MAX_AGGREGATE_SIZE));
|
||||||
|
return addAggregation(searchSourceBuilder);
|
||||||
|
}
|
||||||
|
|
||||||
|
private static SearchSourceBuilder buildDataAssetsSearchBuilder(
|
||||||
|
String query, int from, int size) {
|
||||||
|
QueryStringQueryBuilder queryStringBuilder =
|
||||||
|
buildSearchQueryBuilder(query, SearchIndex.getAllFields());
|
||||||
|
FunctionScoreQueryBuilder queryBuilder = boostScore(queryStringBuilder);
|
||||||
|
SearchSourceBuilder searchSourceBuilder = searchBuilder(queryBuilder, null, from, size);
|
||||||
searchSourceBuilder.aggregation(
|
searchSourceBuilder.aggregation(
|
||||||
AggregationBuilders.terms("database.name.keyword")
|
AggregationBuilders.terms("database.name.keyword")
|
||||||
.field("database.name.keyword")
|
.field("database.name.keyword")
|
||||||
@ -2310,7 +2327,8 @@ public class ElasticSearchClient implements SearchClient {
|
|||||||
"storage_service_index",
|
"storage_service_index",
|
||||||
"search_service_index",
|
"search_service_index",
|
||||||
"metadata_service_index" -> buildServiceSearchBuilder(q, from, size);
|
"metadata_service_index" -> buildServiceSearchBuilder(q, from, size);
|
||||||
case "all", "dataAsset" -> buildSearchAcrossIndexesBuilder(q, from, size);
|
case "dataAsset" -> buildDataAssetsSearchBuilder(q, from, size);
|
||||||
|
case "all" -> buildSearchAcrossIndexesBuilder(q, from, size);
|
||||||
default -> buildAggregateSearchBuilder(q, from, size);
|
default -> buildAggregateSearchBuilder(q, from, size);
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
@ -1282,6 +1282,24 @@ public class OpenSearchClient implements SearchClient {
|
|||||||
FunctionScoreQueryBuilder queryBuilder = boostScore(queryStringBuilder);
|
FunctionScoreQueryBuilder queryBuilder = boostScore(queryStringBuilder);
|
||||||
queryBuilder.boostMode(CombineFunction.SUM);
|
queryBuilder.boostMode(CombineFunction.SUM);
|
||||||
SearchSourceBuilder searchSourceBuilder = searchBuilder(queryBuilder, null, from, size);
|
SearchSourceBuilder searchSourceBuilder = searchBuilder(queryBuilder, null, from, size);
|
||||||
|
searchSourceBuilder.aggregation(
|
||||||
|
AggregationBuilders.terms("database.name.keyword")
|
||||||
|
.field("database.name.keyword")
|
||||||
|
.size(MAX_AGGREGATE_SIZE));
|
||||||
|
searchSourceBuilder.aggregation(
|
||||||
|
AggregationBuilders.terms("databaseSchema.name.keyword")
|
||||||
|
.field("databaseSchema.name.keyword")
|
||||||
|
.size(MAX_AGGREGATE_SIZE));
|
||||||
|
return addAggregation(searchSourceBuilder);
|
||||||
|
}
|
||||||
|
|
||||||
|
private static SearchSourceBuilder buildDataAssetsSearchBuilder(
|
||||||
|
String query, int from, int size) {
|
||||||
|
QueryStringQueryBuilder queryStringBuilder =
|
||||||
|
buildSearchQueryBuilder(query, SearchIndex.getAllFields());
|
||||||
|
FunctionScoreQueryBuilder queryBuilder = boostScore(queryStringBuilder);
|
||||||
|
queryBuilder.boostMode(CombineFunction.SUM);
|
||||||
|
SearchSourceBuilder searchSourceBuilder = searchBuilder(queryBuilder, null, from, size);
|
||||||
searchSourceBuilder.aggregation(
|
searchSourceBuilder.aggregation(
|
||||||
AggregationBuilders.terms("database.name.keyword")
|
AggregationBuilders.terms("database.name.keyword")
|
||||||
.field("database.name.keyword")
|
.field("database.name.keyword")
|
||||||
@ -2288,7 +2306,8 @@ public class OpenSearchClient implements SearchClient {
|
|||||||
"storage_service_index",
|
"storage_service_index",
|
||||||
"search_service_index",
|
"search_service_index",
|
||||||
"metadata_service_index" -> buildServiceSearchBuilder(q, from, size);
|
"metadata_service_index" -> buildServiceSearchBuilder(q, from, size);
|
||||||
case "all", "dataAsset" -> buildSearchAcrossIndexesBuilder(q, from, size);
|
case "dataAsset" -> buildDataAssetsSearchBuilder(q, from, size);
|
||||||
|
case "all" -> buildSearchAcrossIndexesBuilder(q, from, size);
|
||||||
default -> buildAggregateSearchBuilder(q, from, size);
|
default -> buildAggregateSearchBuilder(q, from, size);
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
@ -449,6 +449,10 @@
|
|||||||
"type": "text"
|
"type": "text"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
},
|
||||||
|
"serviceType": {
|
||||||
|
"type": "keyword",
|
||||||
|
"normalizer": "lowercase_normalizer"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -429,6 +429,10 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
"serviceType": {
|
||||||
|
"type": "keyword",
|
||||||
|
"normalizer": "lowercase_normalizer"
|
||||||
|
},
|
||||||
"totalVotes": {
|
"totalVotes": {
|
||||||
"type": "long",
|
"type": "long",
|
||||||
"null_value": 0
|
"null_value": 0
|
||||||
|
@ -418,6 +418,10 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
"serviceType": {
|
||||||
|
"type": "keyword",
|
||||||
|
"normalizer": "lowercase_normalizer"
|
||||||
|
},
|
||||||
"totalVotes": {
|
"totalVotes": {
|
||||||
"type": "long",
|
"type": "long",
|
||||||
"null_value": 0
|
"null_value": 0
|
||||||
|
Loading…
x
Reference in New Issue
Block a user