You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by am...@apache.org on 2020/11/13 18:40:25 UTC
[atlas] 02/02: ATLAS-4025 ATLAS-4023: Import Service: Lables and
Classifications not getting updated.
This is an automated email from the ASF dual-hosted git repository.
amestry pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git
commit 4ab95b9adafd3d845b626d2d82bd2b3aa23be691
Author: Ashutosh Mestry <am...@cloudera.com>
AuthorDate: Fri Nov 13 10:26:25 2020 -0800
ATLAS-4025 ATLAS-4023: Import Service: Lables and Classifications not getting updated.
---
.../apache/atlas/repository/store/graph/v2/EntityGraphMapper.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphMapper.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphMapper.java
index 14876b1..2cfcc0b 100644
--- a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphMapper.java
+++ b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphMapper.java
@@ -255,6 +255,10 @@ public class EntityGraphMapper {
if (entity.getCustomAttributes() != null) {
setCustomAttributes(vertex, entity);
}
+
+ if (entity.getLabels() != null) {
+ setLabels(vertex, entity.getLabels());
+ }
}
public EntityMutationResponse mapAttributesAndClassifications(EntityMutationContext context, final boolean isPartialUpdate, final boolean replaceClassifications, boolean replaceBusinessAttributes) throws AtlasBaseException {
@@ -299,8 +303,6 @@ public class EntityGraphMapper {
mapAttributes(updatedEntity, entityType, vertex, updateType, context);
setCustomAttributes(vertex,updatedEntity);
- resp.addEntity(updateType, constructHeader(updatedEntity, vertex));
-
if (replaceClassifications) {
deleteClassifications(guid);
addClassifications(context, guid, updatedEntity.getClassifications());
@@ -310,6 +312,7 @@ public class EntityGraphMapper {
setBusinessAttributes(vertex, entityType, updatedEntity.getBusinessAttributes());
}
+ resp.addEntity(updateType, constructHeader(updatedEntity, vertex));
reqContext.cache(updatedEntity);
}
}