diff --git a/auth-agents-common/src/main/java/org/apache/atlas/plugin/util/RangerPolicyDeltaUtil.java b/auth-agents-common/src/main/java/org/apache/atlas/plugin/util/RangerPolicyDeltaUtil.java
index 0c8267b5c7..340dcbec15 100644
--- a/auth-agents-common/src/main/java/org/apache/atlas/plugin/util/RangerPolicyDeltaUtil.java
+++ b/auth-agents-common/src/main/java/org/apache/atlas/plugin/util/RangerPolicyDeltaUtil.java
@@ -92,7 +92,7 @@ public static List<RangerPolicy> applyDeltas(List<RangerPolicy> policies, List<R
                         while (iter.hasNext()) {
                             RangerPolicy policy = iter.next();
                             if (
-                                    (changeType == RangerPolicyDelta.CHANGE_TYPE_POLICY_UPDATE && policyId.equals(policy.getGuid())) ||
+                                    (changeType == RangerPolicyDelta.CHANGE_TYPE_POLICY_UPDATE && policyId.equals(policy.getAtlasGuid())) ||
                                     (changeType == RangerPolicyDelta.CHANGE_TYPE_POLICY_DELETE && policyId.equals(policy.getAtlasGuid()))
                             ){
                                 deletedPolicies.add(policy);
@@ -108,7 +108,7 @@ public static List<RangerPolicy> applyDeltas(List<RangerPolicy> policies, List<R
                                 break;
                             }
                             case RangerPolicyDelta.CHANGE_TYPE_POLICY_UPDATE: {
-                                if (CollectionUtils.isEmpty(deletedPolicies) || deletedPolicies.size() > 1) {
+                                if (CollectionUtils.isEmpty(deletedPolicies)) {
                                     LOG.warn("Unexpected: found no policy or multiple policies for CHANGE_TYPE_POLICY_UPDATE: " + Arrays.toString(deletedPolicies.toArray()));
                                 }
                                 break;