[atlas] branch master updated: ATLAS-4481: Fixed NPE at Atlas API on update classifications without propagate flag

[sidmishra]

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

sidmishra 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 7211f47  ATLAS-4481: Fixed NPE at Atlas API on update classifications 
without propagate flag
7211f47 is described below

commit 7211f4724fe827ebec1a6c1891a9b46b72f3553f
Author: Sidharth Mishra <sidharthkmis...@gmail.com>
AuthorDate: Tue Nov 16 13:26:06 2021 -0800

    ATLAS-4481: Fixed NPE at Atlas API on update classifications without 
propagate flag
    
    Signed-off-by: Sidharth Mishra <sidmis...@apache.org>
---
 .../apache/atlas/repository/store/graph/v2/EntityGraphMapper.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 6d8305a..f6c50bc 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
@@ -1065,7 +1065,7 @@ public class EntityGraphMapper {
                 if (trimmedLength < value.length()) {
                     LOG.warn("Length of indexed attribute {} is {} characters, 
longer than safe-limit {}; trimming to {} - attempt #{}", 
attribute.getQualifiedName(), value.length(), INDEXED_STR_SAFE_LEN, 
trimmedLength, requestContext.getAttemptCount());
 
-                    String checksumSuffix = ":" + DigestUtils.shaHex(value); 
// Storing SHA checksum in case verification is needed after retrieval
+                    String checksumSuffix = ":" + 
DigestUtils.sha256Hex(value); // Storing SHA checksum in case verification is 
needed after retrieval
 
                     ret = value.substring(0, trimmedLength - 
checksumSuffix.length()) + checksumSuffix;
                 } else {
@@ -2407,7 +2407,7 @@ public class EntityGraphMapper {
                |   true      |    false    | => Remove Tag Propagation (send 
REMOVE classification notifications)
                |-------------|-------------| */
 
-            if (taskManagement != null && DEFERRED_ACTION_ENABLED) {
+            if (updatedTagPropagation != null && taskManagement != null && 
DEFERRED_ACTION_ENABLED) {
                 String propagationType = updatedTagPropagation ? 
CLASSIFICATION_PROPAGATION_ADD : CLASSIFICATION_PROPAGATION_DELETE;
 
                 createAndQueueTask(propagationType, entityVertex, 
classificationVertex.getIdForDisplay());
@@ -2840,4 +2840,4 @@ public class EntityGraphMapper {
 
         AtlasGraphUtilsV2.removeItemFromListProperty(edge, 
EDGE_PENDING_TASKS_PROPERTY_KEY, taskGuid);
     }
-}
\ No newline at end of file
+}