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() {