diff --git a/repository/src/main/java/org/apache/atlas/discovery/EntityLineageService.java b/repository/src/main/java/org/apache/atlas/discovery/EntityLineageService.java
index 4f169d9027..01fa5108ab 100644
--- a/repository/src/main/java/org/apache/atlas/discovery/EntityLineageService.java
+++ b/repository/src/main/java/org/apache/atlas/discovery/EntityLineageService.java
@@ -654,31 +654,40 @@ private void processEdge(final AtlasEdge edge, final Map<String, AtlasEntityHead
         String      relationGuid = AtlasGraphUtilsV2.getEncodedProperty(edge, RELATIONSHIP_GUID_PROPERTY_KEY, String.class);
         boolean     isInputEdge  = edge.getLabel().equalsIgnoreCase(PROCESS_INPUTS_EDGE);
 
-        if (!entities.containsKey(inGuid)) {
-            AtlasEntityHeader entityHeader = entityRetriever.toAtlasEntityHeader(inVertex);
+        addEntityHeaderIfAuthorized(inVertex, inGuid, entities);
+        addEntityHeaderIfAuthorized(outVertex, outGuid, entities);
 
-            entities.put(inGuid, entityHeader);
+        if (entities.containsKey(inGuid) && entities.containsKey(outGuid)) {
+            if (isInputEdge) {
+                relations.add(new LineageRelation(inGuid, outGuid, relationGuid));
+            } else {
+                relations.add(new LineageRelation(outGuid, inGuid, relationGuid));
+            }
         }
 
-        if (!entities.containsKey(outGuid)) {
-            AtlasEntityHeader entityHeader = entityRetriever.toAtlasEntityHeader(outVertex);
+        if (visitedEdges != null) {
+            String visitedEdgeLabel = isInputEdge ? getVisitedEdgeLabel(inGuid, outGuid, relationGuid) : getVisitedEdgeLabel(outGuid, inGuid, relationGuid);
 
-            entities.put(outGuid, entityHeader);
+            visitedEdges.add(visitedEdgeLabel);
         }
+    }
 
-        if (isInputEdge) {
-            relations.add(new LineageRelation(inGuid, outGuid, relationGuid));
-        } else {
-            relations.add(new LineageRelation(outGuid, inGuid, relationGuid));
+    private void addEntityHeaderIfAuthorized(AtlasVertex vertex, String guid, Map<String, AtlasEntityHeader> entities) throws AtlasBaseException {
+        if (entities.containsKey(guid)) {
+            return;
         }
 
-        if (visitedEdges != null) {
-            String visitedEdgeLabel = isInputEdge ? getVisitedEdgeLabel(inGuid, outGuid, relationGuid) : getVisitedEdgeLabel(outGuid, inGuid, relationGuid);
+        AtlasEntityHeader entityHeader = entityRetriever.toAtlasEntityHeader(vertex);
 
-            visitedEdges.add(visitedEdgeLabel);
+        if (isEntityReadAllowed(entityHeader)) {
+            entities.put(guid, entityHeader);
         }
     }
 
+    private boolean isEntityReadAllowed(AtlasEntityHeader entityHeader) {
+        return AtlasAuthorizationUtils.isAccessAllowed(new AtlasEntityAccessRequest(atlasTypeRegistry, AtlasPrivilege.ENTITY_READ, entityHeader));
+    }
+
     private AtlasLineageInfo getBothLineageInfoV1(String guid, int depth, boolean isDataSet) throws AtlasBaseException {
         AtlasLineageInfo inputLineage  = getLineageInfo(guid, INPUT, depth, isDataSet);
         AtlasLineageInfo outputLineage = getLineageInfo(guid, OUTPUT, depth, isDataSet);