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 6927b1d1c4..7c69099e74 100644 --- a/repository/src/main/java/org/apache/atlas/discovery/EntityLineageService.java +++ b/repository/src/main/java/org/apache/atlas/discovery/EntityLineageService.java @@ -653,7 +653,7 @@ private List getFilteredAtlasEdges(AtlasVertex outVertex, String proc } private boolean isEntityTraversalLimitReached(AtomicInteger entitiesTraversed) { - return entitiesTraversed.get() == getLineageMaxNodeAllowedCount(); + return entitiesTraversed.get() >= getLineageMaxNodeAllowedCount(); } @Override