diff --git a/open-metadata-implementation/adapters/open-connectors/governance-daemon-connectors/open-lineage-connectors/open-lineage-janus-connector/src/main/java/org/odpi/openmetadata/openconnectors/governancedaemonconnectors/openlineageconnectors/janusconnector/graph/LineageGraphConnectorHelper.java b/open-metadata-implementation/adapters/open-connectors/governance-daemon-connectors/open-lineage-connectors/open-lineage-janus-connector/src/main/java/org/odpi/openmetadata/openconnectors/governancedaemonconnectors/openlineageconnectors/janusconnector/graph/LineageGraphConnectorHelper.java index 72993efd1a1..d1f91187a41 100644 --- a/open-metadata-implementation/adapters/open-connectors/governance-daemon-connectors/open-lineage-connectors/open-lineage-janus-connector/src/main/java/org/odpi/openmetadata/openconnectors/governancedaemonconnectors/openlineageconnectors/janusconnector/graph/LineageGraphConnectorHelper.java +++ b/open-metadata-implementation/adapters/open-connectors/governance-daemon-connectors/open-lineage-connectors/open-lineage-janus-connector/src/main/java/org/odpi/openmetadata/openconnectors/governancedaemonconnectors/openlineageconnectors/janusconnector/graph/LineageGraphConnectorHelper.java @@ -230,7 +230,7 @@ private Optional glossaryVerticalLineage(String guid) { Graph subGraph = (Graph) g.V().has(PROPERTY_KEY_ENTITY_GUID, guid).bothE(glossaryTermAndClassificationEdges) .subgraph("s").cap("s").next(); - return Optional.of(getLineageVerticesAndEdges(subGraph, false)); + return Optional.of(getLineageVerticesAndEdges(subGraph, true)); } /** @@ -246,7 +246,7 @@ private Optional relationalColumnVerticalLineage(String Graph subGraph = (Graph) g.V().has(PROPERTY_KEY_ENTITY_GUID, guid).bothE(relationalColumnAndClassificationEdges) .subgraph("s").cap("s").next(); - return Optional.of(getLineageVerticesAndEdges(subGraph, false)); + return Optional.of(getLineageVerticesAndEdges(subGraph, true)); } /** @@ -262,7 +262,7 @@ private Optional tabularColumnVerticalLineage(String gu Graph subGraph = (Graph) g.V().has(PROPERTY_KEY_ENTITY_GUID, guid).bothE(tabularColumnAndClassificationEdges) .subgraph("s").bothV().inE(ASSET_SCHEMA_TYPE).subgraph("s").cap("s").next(); - return Optional.of(getLineageVerticesAndEdges(subGraph, false)); + return Optional.of(getLineageVerticesAndEdges(subGraph, true)); } /**