tool
/
atlas
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Revert "ATLAS-4859 : NPE during Atlas Import" 

This reverts commit 4e788f5d1f.
This commit is contained in:
Pinal Shah 2024-09-25 18:18:28 +07:00
parent c6ceaa3454
commit 8dd5088401
1 changed files with 2 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
repository/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphMapper.java
View File

@ -2255,18 +2255,8 @@ public class EntityGraphMapper {
}
private boolean classificationHasPendingTask(AtlasTask task, String classificationVertexId, String entityGuid) {
if (task.getParameters() != null) {
if (classificationVertexId != null && entityGuid != null) {
return task.getParameters().get(ClassificationTask.PARAM_CLASSIFICATION_VERTEX_ID).equals(classificationVertexId)
&& task.getParameters().get(ClassificationTask.PARAM_ENTITY_GUID).equals(entityGuid);
} else {
LOG.warn("ClassificationVertexId and EntityGuid not found!");
return false;
}
} else {
LOG.warn("No task parameters found!");
return false;
}
return task.getParameters().get(ClassificationTask.PARAM_CLASSIFICATION_VERTEX_ID).equals(classificationVertexId)
&& task.getParameters().get(ClassificationTask.PARAM_ENTITY_GUID).equals(entityGuid);
}
private AtlasEntity updateClassificationText(AtlasVertex vertex) throws AtlasBaseException {