Skip to content

A
atlas
Commit 0cde9f92 by Sarath Subramanian
Options

ATLAS-2550: On deleting entity with classification , classification is removed…

ATLAS-2550: On deleting entity with classification , classification is removed from the entity, but search on classification lists the entity
parent 8d1e7223
Showing with 5 additions and 0 deletions
repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java
...@@ -51,6 +51,7 @@ import static org.apache.atlas.model.instance.AtlasClassification.PropagationSta ...@@ -51,6 +51,7 @@ import static org.apache.atlas.model.instance.AtlasClassification.PropagationSta
import static org.apache.atlas.model.instance.AtlasEntity.Status.DELETED; import static org.apache.atlas.model.instance.AtlasEntity.Status.DELETED;
import static org.apache.atlas.repository.Constants.CLASSIFICATION_LABEL; import static org.apache.atlas.repository.Constants.CLASSIFICATION_LABEL;
import static org.apache.atlas.repository.Constants.PROPAGATED_TRAIT_NAMES_PROPERTY_KEY; import static org.apache.atlas.repository.Constants.PROPAGATED_TRAIT_NAMES_PROPERTY_KEY;
import static org.apache.atlas.repository.Constants.TRAIT_NAMES_PROPERTY_KEY;
import static org.apache.atlas.repository.graph.GraphHelper.EDGE_LABEL_PREFIX; import static org.apache.atlas.repository.graph.GraphHelper.EDGE_LABEL_PREFIX;
import static org.apache.atlas.repository.graph.GraphHelper.addToPropagatedTraitNames; import static org.apache.atlas.repository.graph.GraphHelper.addToPropagatedTraitNames;
import static org.apache.atlas.repository.graph.GraphHelper.getClassificationEdgeState; import static org.apache.atlas.repository.graph.GraphHelper.getClassificationEdgeState;
...@@ -498,6 +499,10 @@ public abstract class DeleteHandlerV1 { ...@@ -498,6 +499,10 @@ public abstract class DeleteHandlerV1 {
for (AtlasEdge edge : classificationEdges) { for (AtlasEdge edge : classificationEdges) {
deleteEdgeReference(edge, TypeCategory.CLASSIFICATION, false, false, instanceVertex); deleteEdgeReference(edge, TypeCategory.CLASSIFICATION, false, false, instanceVertex);
} }
//remove traitNames and propagatedTraitNames property from instanceVertex
instanceVertex.removeProperty(TRAIT_NAMES_PROPERTY_KEY);
instanceVertex.removeProperty(PROPAGATED_TRAIT_NAMES_PROPERTY_KEY);
} }
protected AtlasAttribute getAttributeForEdge(String edgeLabel) throws AtlasBaseException { protected AtlasAttribute getAttributeForEdge(String edgeLabel) throws AtlasBaseException {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment