ATLAS-2781: Hard Delete : Deleting an entity which is associated to an term…

ATLAS-2781: Hard Delete : Deleting an entity which is associated to an term associated to a tag fails

ATLAS-2781: Hard Delete : Deleting an entity which is associated to an term…
59ae59db · Sarath Subramanian · ec396b93 · 59ae59db
Commit 59ae59db authored 6 years ago by Sarath Subramanian
Show whitespace changes
Inline Side-by-side

Showing with 7 additions and 0 deletions

AtlasEntityChangeNotifier.java .../repository/store/graph/v2/AtlasEntityChangeNotifier.java +7 -0

No files found.
--- a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasEntityChangeNotifier.java
+++ b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasEntityChangeNotifier.java
@@ -246,7 +246,14 @@ public class AtlasEntityChangeNotifier {
            return;
        }

+        RequestContext context = RequestContext.get();
+
        for (String guid : entityPropagationMap.keySet()) {
+            // if entity is deleted, don't send propagated classifications add/remove notifications.
+            if (context.isDeletedEntity(guid)) {
+                continue;
+            }
+
            AtlasEntityWithExtInfo entityWithExtInfo = instanceConverter.getAndCacheEntity(guid);
            AtlasEntity            entity            = entityWithExtInfo != null ? entityWithExtInfo.getEntity() : null;