From 3ce45e14d7564e7eef29ae353d1e1b2f610d34b9 Mon Sep 17 00:00:00 2001 From: Nikhil Soni Date: Wed, 1 Oct 2025 21:10:16 +0530 Subject: [PATCH] Handle null value for Integer --- .../atlas/policytransformer/CachePolicyTransformerImpl.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/auth-agents-common/src/main/java/org/apache/atlas/policytransformer/CachePolicyTransformerImpl.java b/auth-agents-common/src/main/java/org/apache/atlas/policytransformer/CachePolicyTransformerImpl.java index bf5d6662564..5914de7c082 100644 --- a/auth-agents-common/src/main/java/org/apache/atlas/policytransformer/CachePolicyTransformerImpl.java +++ b/auth-agents-common/src/main/java/org/apache/atlas/policytransformer/CachePolicyTransformerImpl.java @@ -387,6 +387,9 @@ private List getRangerPolicyDelta(AtlasEntityHeader service, List deletedPolicyDeltas = new ArrayList<>(); for (String policyGuid : policyGuids) { Integer deltaChangeType = auditEventToDeltaChangeType.get(policyChanges.get(policyGuid)); + if (deltaChangeType == null) { + continue; + } if (deltaChangeType == RangerPolicyDelta.CHANGE_TYPE_POLICY_DELETE) { RangerPolicy deletedPolicy = new RangerPolicy(); deletedPolicy.setGuid(policyGuid);