diff --git a/common/src/java/org/apache/hadoop/hive/common/LogUtils.java b/common/src/java/org/apache/hadoop/hive/common/LogUtils.java index 0a3e0c72011951b6b1543352308bd51233c847fb..56c56062ce59f001bb83fdd9e1cce864f1f9dd8f 100644 --- a/common/src/java/org/apache/hadoop/hive/common/LogUtils.java +++ b/common/src/java/org/apache/hadoop/hive/common/LogUtils.java @@ -256,6 +256,9 @@ public static void stopQueryAppender(String routingAppenderName, String queryId) // this will cause the subordinate appender to close its output stream. subordinateAppender.stop(); } + method = clazz.getDeclaredMethod("deleteAppender", String.class); + method.setAccessible(true); + method.invoke(routingAppender, queryId); } catch (NoSuchMethodException | SecurityException | IllegalAccessException | IllegalArgumentException | InvocationTargetException e) { l4j.warn("Unable to close the operation log appender for query id " + queryId, e);