ATLAS-4859: NPE during Atlas Import

Signed-off-by: Pinal Shah <pinal.shah@freestoneinfotech.com>
This commit is contained in:
Pinal Shah 2024-09-26 10:09:28 +07:00
parent 8dd5088401
commit 5a65d2d5ff
1 changed files with 6 additions and 0 deletions

View File

@ -2255,6 +2255,12 @@ public class EntityGraphMapper {
}
private boolean classificationHasPendingTask(AtlasTask task, String classificationVertexId, String entityGuid) {
if (task.getParameters() == null
|| task.getParameters().get(ClassificationTask.PARAM_CLASSIFICATION_VERTEX_ID) == null
|| task.getParameters().get(ClassificationTask.PARAM_ENTITY_GUID) == null) {
return false;
}
return task.getParameters().get(ClassificationTask.PARAM_CLASSIFICATION_VERTEX_ID).equals(classificationVertexId)
&& task.getParameters().get(ClassificationTask.PARAM_ENTITY_GUID).equals(entityGuid);
}