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 420e4807cd..084a8908e1 100644 --- a/repository/src/main/java/org/apache/atlas/discovery/EntityLineageService.java +++ b/repository/src/main/java/org/apache/atlas/discovery/EntityLineageService.java @@ -495,10 +495,7 @@ private void enqueueNeighbours(AtlasVertex currentVertex, boolean isDataset, Atl neighbourVertex = currentEdge.getInVertex(); String vertexGuid = getGuid(neighbourVertex); - if (StringUtils.isEmpty(vertexGuid)) - continue; - - if (!lineageListContext.evaluateTraversalFilter(neighbourVertex)) + if (StringUtils.isEmpty(vertexGuid) || !lineageListContext.evaluateTraversalFilter(neighbourVertex)) continue; if (!skippedVertices.contains(vertexGuid) && !visitedVertices.contains(vertexGuid)) {