diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java index c89b5c2375b..43fb33e03a9 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java @@ -417,7 +417,8 @@ public class LineageRepository { lineageData.setPipeline(null); } else { Pair> pipelineOrStoredProcedure = - getPipelineOrStoredProcedure(pipelineRef, List.of("changeDescription")); + getPipelineOrStoredProcedure( + pipelineRef, List.of("changeDescription", "incrementalChangeDescription")); lineageData.setPipelineEntityType(pipelineOrStoredProcedure.getLeft()); lineageData.setPipeline(pipelineOrStoredProcedure.getRight()); } diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/search/indexes/SearchIndex.java b/openmetadata-service/src/main/java/org/openmetadata/service/search/indexes/SearchIndex.java index 788df8bfc2c..bad99694900 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/search/indexes/SearchIndex.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/search/indexes/SearchIndex.java @@ -54,7 +54,8 @@ public interface SearchIndex { "incrementalChangeDescription", "upstreamLineage.pipeline.changeDescription", "upstreamLineage.pipeline.incrementalChangeDescription", - "connection"); + "connection", + "changeSummary"); public static final SearchClient searchClient = Entity.getSearchRepository().getSearchClient();