Merge pull request #5475 from atlanhq/ns/fix/itau

ADMIN-374 Fix policy refresh when persona is disabled

Author: krsoninikhil

auth-agents-common/src/main/java/org/apache/atlas/policytransformer/CachePolicyTransformerImpl.java

@@ -418,6 +418,10 @@ public Map<String, EntityAuditActionV2> createPolicyChangeMap(String serviceName
         Map<String, EntityAuditActionV2> policyChanges = new HashMap<>();
         for (EntityAuditEventV2 event : events) {
             if (POLICY_ENTITY_TYPE.equals(event.getTypeName()) && !policyChanges.containsKey(event.getEntityId())) {
+                if (auditEventToDeltaChangeType.get(event.getAction()) == null) {
+                    LOG.warn("PolicyDelta: {}: No delta type found for audit_event={} guid={}", serviceName, event.getAction(), event.getEntityId());
+                    continue;
+                }
                 policyChanges.put(event.getEntityId(), event.getAction());
             }
         }

auth-audits/src/main/java/org/apache/atlas/audit/destination/Log4JAuditDestination.java

@@ -46,6 +46,7 @@ public class Log4JAuditDestination extends AuditDestination {
 	private static final String AUTH_AUDIT_RESOURCE= "resource";
 	private static final String AUTH_AUDIT_CLIENT_IP = "cliIP";
 	private static final String AUTH_AUDIT_AGENT = "agent";
+	private static final String AUTH_AUDIT_ENFORCER = "enforcer";
 
 
 	public Log4JAuditDestination() {
@@ -105,6 +106,7 @@ private void recordLogAttributes(AuditEventBase eventBase) {
 			MDC.put(AUTH_AUDIT_RESULT, String.valueOf(event.getAccessResult()));
 			MDC.put(AUTH_AUDIT_CLIENT_IP, event.getClientIP());
 			MDC.put(AUTH_AUDIT_AGENT, event.getAgentId());
+			MDC.put(AUTH_AUDIT_ENFORCER, event.getAclEnforcer());
 		}
 	}
 
@@ -118,6 +120,7 @@ private void clearLogAttributes(AuditEventBase event) {
 			MDC.remove(AUTH_AUDIT_RESULT);
 			MDC.remove(AUTH_AUDIT_CLIENT_IP);
 			MDC.remove(AUTH_AUDIT_AGENT);
+			MDC.remove(AUTH_AUDIT_ENFORCER);
 		}
 	}