From 6168efdda9331dd2fce03f813b1d58c75dcb0243 Mon Sep 17 00:00:00 2001 From: Henry Liu Date: Wed, 14 Oct 2020 16:03:39 -0700 Subject: [PATCH] [hive][audit_log] change hive audit log format to be compatible with flink-based rh event logging pipeline --- .../apache/hadoop/hive/metastore/HiveMetaStore.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index a9398ae1e794..ad44743fc83d 100644 --- a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -66,6 +66,8 @@ import javax.jdo.JDOException; import com.codahale.metrics.Counter; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.node.ObjectNode; import com.google.common.collect.Lists; import org.apache.commons.cli.OptionBuilder; @@ -351,7 +353,13 @@ private static void logAuditEvent(String cmd) { address = "unknown-ip-addr"; } - auditLog.info("ugi={} ip={} cmd={} ", ugi.getUserName(), address, cmd); + ObjectMapper mapper = new ObjectMapper(); + ObjectNode metricNode = mapper.createObjectNode(); + metricNode.put("ugi", ugi.getUserName()); + metricNode.put("ip", address); + metricNode.put("cmd", cmd); + auditLog.info(metricNode.toString()); + // auditLog.info("ugi={} ip={} cmd={} ", ugi.getUserName(), address, cmd); } private static String getIPAddress() {