Author: bobby
Date: Tue Nov 6 18:48:49 2012
New Revision: 1406269
URL: http://svn.apache.org/viewvc?rev=1406269&view=rev
Log:
YARN-202. Log Aggregation generates a storm of fsync() for namenode (Kihwal Lee
via bobby)
Modified:
hadoop/common/trunk/hadoop-yarn-project/CHANGES.txt
hadoop/common/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/AggregatedLogFormat.java
Modified: hadoop/common/trunk/hadoop-yarn-project/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-yarn-project/CHANGES.txt?rev=1406269&r1=1406268&r2=1406269&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-yarn-project/CHANGES.txt (original)
+++ hadoop/common/trunk/hadoop-yarn-project/CHANGES.txt Tue Nov 6 18:48:49 2012
@@ -199,6 +199,9 @@ Release 0.23.5 - UNRELEASED
YARN-189. Fixed a deadlock between RM's ApplicationMasterService and the
dispatcher. (Thomas Graves via vinodkv)
+ YARN-202. Log Aggregation generates a storm of fsync() for namenode
+ (Kihwal Lee via bobby)
+
Release 0.23.4 - UNRELEASED
INCOMPATIBLE CHANGES
Modified:
hadoop/common/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/AggregatedLogFormat.java
URL:
http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/AggregatedLogFormat.java?rev=1406269&r1=1406268&r2=1406269&view=diff
==============================================================================
---
hadoop/common/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/AggregatedLogFormat.java
(original)
+++
hadoop/common/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/AggregatedLogFormat.java
Tue Nov 6 18:48:49 2012
@@ -263,7 +263,6 @@ public class AggregatedLogFormat {
out = this.writer.prepareAppendValue(-1);
logValue.write(out);
out.close();
- this.fsDataOStream.hflush();
}
public void closeWriter() {
