diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/elasticsearch/ElasticSearchIndexDefinition.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/elasticsearch/ElasticSearchIndexDefinition.java index 78455f3318c..b52a3af168d 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/elasticsearch/ElasticSearchIndexDefinition.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/elasticsearch/ElasticSearchIndexDefinition.java @@ -633,7 +633,7 @@ class DashboardESIndex extends ElasticSearchIndex { @Value @JsonInclude(JsonInclude.Include.NON_NULL) class PipelineESIndex extends ElasticSearchIndex { - @JsonProperty("pipeine_id") + @JsonProperty("pipeline_id") String pipelineId; @JsonProperty("task_names") @@ -666,9 +666,10 @@ class PipelineESIndex extends ElasticSearchIndex { internalBuilder() .pipelineId(pipeline.getId().toString()) .deleted(pipeline.getDeleted()) - .name(pipeline.getDisplayName()) - .displayName(description) - .description(displayName) + .name( + displayName) // pipeline names can be unique ids from source, hence use displayName for search indexing + .displayName(displayName) + .description(description) .fqdn(pipeline.getFullyQualifiedName()) .lastUpdatedTimestamp(updatedTimestamp) .taskNames(taskNames) 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 35f549134cb..9df98a1aa09 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 @@ -257,7 +257,7 @@ public class SearchResource { private SearchSourceBuilder buildTopicSearchBuilder(String query, int from, int size) { SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); - HighlightBuilder.Field highlightTopicName = new HighlightBuilder.Field("topic_name"); + HighlightBuilder.Field highlightTopicName = new HighlightBuilder.Field("name"); highlightTopicName.highlighterType("unified"); HighlightBuilder.Field highlightDescription = new HighlightBuilder.Field("description"); highlightDescription.highlighterType("unified"); @@ -282,7 +282,7 @@ public class SearchResource { private SearchSourceBuilder buildDashboardSearchBuilder(String query, int from, int size) { SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); - HighlightBuilder.Field highlightDashboardName = new HighlightBuilder.Field("dashboard_name"); + HighlightBuilder.Field highlightDashboardName = new HighlightBuilder.Field("name"); highlightDashboardName.highlighterType("unified"); HighlightBuilder.Field highlightDescription = new HighlightBuilder.Field("description"); highlightDescription.highlighterType("unified");