From 7a0d9c867c6906fd3182cf137953ac7578afd1b0 Mon Sep 17 00:00:00 2001 From: Suresh Srinivas Date: Tue, 24 Aug 2021 14:39:02 -0700 Subject: [PATCH] Fix #287: search api not returning all aggregations for Topics index --- .../openmetadata/catalog/resources/search/SearchResource.java | 2 ++ ingestion/examples/kafka_schemas/topics.json | 1 + 2 files changed, 3 insertions(+) diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/search/SearchResource.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/search/SearchResource.java index a22a1c96cc3..377b41bacc8 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/search/SearchResource.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/search/SearchResource.java @@ -213,6 +213,8 @@ public class SearchResource { .field("description") .lenient(true)) .aggregation(AggregationBuilders.terms("Service Type").field("service_type")) + .aggregation(AggregationBuilders.terms("Tier").field("tier")) + .aggregation(AggregationBuilders.terms("Tags").field("tags")) .highlighter(hb) .from(from).size(size); diff --git a/ingestion/examples/kafka_schemas/topics.json b/ingestion/examples/kafka_schemas/topics.json index d89fb5f981b..ab4de2f217e 100644 --- a/ingestion/examples/kafka_schemas/topics.json +++ b/ingestion/examples/kafka_schemas/topics.json @@ -5,6 +5,7 @@ "partitions": 56, "retentionSize": 322122382273, "cleanupPolicies": ["delete"], + "schemaType": "Avro", "schemaText": "{\"namespace\":\"org.open-metadata.kafka\",\"name\":\"Customer\",\"type\":\"record\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"first_name\",\"type\":\"string\"},{\"name\":\"last_name\",\"type\":\"string\"},{\"name\":\"email\",\"type\":\"string\"},{\"name\":\"address_line_1\",\"type\":\"string\"},{\"name\":\"address_line_2\",\"type\":\"string\"},{\"name\":\"post_code\",\"type\":\"string\"},{\"name\":\"country\",\"type\":\"string\"}]}" },