.../apache/hadoop/hive/metastore/HiveMetaStore.java | 18 ++---------------- 1 file changed, 2 insertions(+), 16 deletions(-) diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index 5b353c4..5405058 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -295,20 +295,9 @@ protected Configuration initialValue() { private static ExecutorService threadPool; - public static final String AUDIT_FORMAT = - "ugi=%s\t" + // ugi - "ip=%s\t" + // remote IP - "cmd=%s\t"; // command public static final Logger auditLog = LoggerFactory.getLogger( HiveMetaStore.class.getName() + ".audit"); - private static final ThreadLocal auditFormatter = - new ThreadLocal() { - @Override - protected Formatter initialValue() { - return new Formatter(new StringBuilder(AUDIT_FORMAT.length() * 4)); - } - }; - + private static final void logAuditEvent(String cmd) { if (cmd == null) { return; @@ -320,16 +309,13 @@ private static final void logAuditEvent(String cmd) { } catch (Exception ex) { throw new RuntimeException(ex); } - final Formatter fmt = auditFormatter.get(); - ((StringBuilder) fmt.out()).setLength(0); String address = getIPAddress(); if (address == null) { address = "unknown-ip-addr"; } - auditLog.info(fmt.format(AUDIT_FORMAT, ugi.getUserName(), - address, cmd).toString()); + auditLog.info("ugi={} ip={} cmd={} ", ugi.getUserName(), address, cmd); } private static String getIPAddress() {