diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/ElasticSearchEventHandler.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/ElasticSearchEventHandler.java index 0c98d75f5c7..a03ffc9fd14 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/ElasticSearchEventHandler.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/ElasticSearchEventHandler.java @@ -61,16 +61,21 @@ public class ElasticSearchEventHandler implements EventHandler { Table instance = (Table) entity; Map jsonMap = new HashMap<>(); jsonMap.put("description", instance.getDescription()); - Set tags = new HashSet(); + Set tags = new HashSet<>(); + List columnDescriptions = new ArrayList<>(); instance.getTags().forEach(tag -> tags.add(tag.getTagFQN())); for(Column column: instance.getColumns()) { column.getTags().forEach(tag -> tags.add(tag.getTagFQN())); + columnDescriptions.add(column.getDescription()); } if (!tags.isEmpty()) { List tagsList = new ArrayList<>(); tagsList.addAll(tags); jsonMap.put("tags", tagsList); } + if (!columnDescriptions.isEmpty()) { + jsonMap.put("column_descriptions", columnDescriptions); + } UpdateRequest updateRequest = new UpdateRequest("table_search_index", instance.getId().toString()); updateRequest.doc(jsonMap); client.updateAsync(updateRequest, RequestOptions.DEFAULT, listener);