diff --git a/ql/src/java/org/apache/hadoop/hive/ql/hooks/HiveProtoLoggingHook.java b/ql/src/java/org/apache/hadoop/hive/ql/hooks/HiveProtoLoggingHook.java index 0a096757f7..fe060f4749 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/hooks/HiveProtoLoggingHook.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/hooks/HiveProtoLoggingHook.java @@ -305,10 +305,10 @@ private void writeEvent(HiveHookEventProto event) { for (int retryCount = 0; retryCount <= MAX_RETRIES; ++retryCount) { try { if (eventPerFile) { - LOG.debug("Event per file enabled. Closing proto event file: {}", writer.getPath()); if (!maybeRolloverWriterForDay()) { writer = logger.getWriter(logFileName + "_" + ++logFileCount); } + LOG.debug("Event per file enabled. New proto event file: {}", writer.getPath()); writer.writeProto(event); IOUtils.closeQuietly(writer); writer = null;