Skip to content

A
atlas
Commit 6fbda5bc by Ashutosh Mestry Committed by nixonrodrigues
Options

ATLAS-3381: Addressed ConcurrentPatchProcessor not calling commit.

Signed-off-by: 's avatarnixonrodrigues <nixon@apache.org>
parent b96ce272
Showing with 7 additions and 5 deletions
repository/src/main/java/org/apache/atlas/repository/patches/ConcurrentPatchProcessor.java
...@@ -222,6 +222,7 @@ public abstract class ConcurrentPatchProcessor { ...@@ -222,6 +222,7 @@ public abstract class ConcurrentPatchProcessor {
try { try {
individualItemProcessor.processVertexItem(vertexId, vertex, typeName, entityType); individualItemProcessor.processVertexItem(vertexId, vertex, typeName, entityType);
doCommit();
} catch (AtlasBaseException e) { } catch (AtlasBaseException e) {
LOG.error("Error processing: {}", vertexId, e); LOG.error("Error processing: {}", vertexId, e);
} }
......
repository/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphMapper.java
...@@ -1697,12 +1697,13 @@ public class EntityGraphMapper { ...@@ -1697,12 +1697,13 @@ public class EntityGraphMapper {
} }
public void updateClassificationTextAndNames(AtlasVertex vertex) throws AtlasBaseException { public void updateClassificationTextAndNames(AtlasVertex vertex) throws AtlasBaseException {
String guid = GraphHelper.getGuid(vertex); if (StringUtils.isEmpty(vertex.getProperty(CLASSIFICATION_NAMES_KEY, String.class))) {
AtlasEntity entity = instanceConverter.getAndCacheEntity(guid); return;
}
if (CollectionUtils.isEmpty(entity.getClassifications())) return;
List<String> classificationNames = new ArrayList<>(); String guid = GraphHelper.getGuid(vertex);
AtlasEntity entity = instanceConverter.getAndCacheEntity(guid);
List<String> classificationNames = new ArrayList<>();
List<String> propagatedClassificationNames = new ArrayList<>(); List<String> propagatedClassificationNames = new ArrayList<>();
for (AtlasClassification classification : entity.getClassifications()) { for (AtlasClassification classification : entity.getClassifications()) {
......
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