Author: vinodkv
Date: Wed Jan 22 18:45:59 2014
New Revision: 1560467
URL: http://svn.apache.org/r1560467
Log:
YARN-321. Forwarding YARN-321 branch to latest trunk.
Modified:
hadoop/common/branches/YARN-321/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/ContainerLogAppender.java
Modified:
hadoop/common/branches/YARN-321/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/ContainerLogAppender.java
URL:
http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/ContainerLogAppender.java?rev=1560467&r1=1560466&r2=1560467&view=diff
==============================================================================
---
hadoop/common/branches/YARN-321/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/ContainerLogAppender.java
(original)
+++
hadoop/common/branches/YARN-321/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/ContainerLogAppender.java
Wed Jan 22 18:45:59 2014
@@ -19,6 +19,7 @@
package org.apache.hadoop.yarn;
import java.io.File;
+import java.io.Flushable;
import java.util.LinkedList;
import java.util.Queue;
@@ -33,7 +34,9 @@ import org.apache.log4j.spi.LoggingEvent
*/
@Public
@Unstable
-public class ContainerLogAppender extends FileAppender {
+public class ContainerLogAppender extends FileAppender
+ implements Flushable
+{
private String containerLogDir;
//so that log4j can configure it from the configuration(log4j.properties).
private int maxEvents;
@@ -65,6 +68,7 @@ public class ContainerLogAppender extend
}
}
+ @Override
public void flush() {
if (qw != null) {
qw.flush();