(atlas) branch branch-2.0 updated: ATLAS-4859: NPE during Atlas Import

[pinal]

This is an automated email from the ASF dual-hosted git repository.

pinal pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/atlas.git


The following commit(s) were added to refs/heads/branch-2.0 by this push:
     new b5e117aba ATLAS-4859: NPE during Atlas Import
b5e117aba is described below

commit b5e117abac48475a2fc890b51ba239893a4b45d0
Author: Pinal Shah <pinal.s...@freestoneinfotech.com>
AuthorDate: Thu Sep 26 10:09:28 2024 +0700

    ATLAS-4859: NPE during Atlas Import
    
    Signed-off-by: Pinal Shah <pinal.s...@freestoneinfotech.com>
---
 .../apache/atlas/repository/store/graph/v2/EntityGraphMapper.java   | 6 ++++++
 1 file changed, 6 insertions(+)

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 9d96fc1cc..7bdd03d75 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
@@ -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);
     }