commit 59ae59dbaf8ce4a35886d5a9e5af7020666b1763
author Sarath Subramanian <ssubramanian@hortonworks.com> Fri Jul 06 15:24:41 2018 -0700
committer Sarath Subramanian <ssubramanian@hortonworks.com> Fri Jul 06 15:24:41 2018 -0700
tree c4c41a41b0cccae7de3084a8ec42ce774ff5e4e2
parent ec396b931b21df05ce52d4b323370ac9e64b426b

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

repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasEntityChangeNotifier.java

diff --git 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
index deb79e5..65c1e77 100644
--- 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 @@
             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;