This is an automated email from the ASF dual-hosted git repository.
pinal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git
The following commit(s) were added to refs/heads/master by this push:
new 5a65d2d5f ATLAS-4859: NPE during Atlas Import
5a65d2d5f is described below
commit 5a65d2d5ffa4d4ac3b0620ac0ecc08eba795ddf1
Author: Pinal Shah <[email protected]>
AuthorDate: Thu Sep 26 10:09:28 2024 +0700
ATLAS-4859: NPE during Atlas Import
Signed-off-by: Pinal Shah <[email protected]>
---
.../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);
}