You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@chukwa.apache.org by as...@apache.org on 2010/04/12 21:01:42 UTC
svn commit: r933365 -
/hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java
Author: asrabkin
Date: Mon Apr 12 19:01:42 2010
New Revision: 933365
URL: http://svn.apache.org/viewvc?rev=933365&view=rev
Log:
CHUKWA-466. Fix failing test cases.
Modified:
hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java
Modified: hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java?rev=933365&r1=933364&r2=933365&view=diff
==============================================================================
--- hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java (original)
+++ hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java Mon Apr 12 19:01:42 2010
@@ -153,6 +153,7 @@ public class SocketTeeWriter extends Pip
out.write(data);
}
}
+ out.flush();
} catch(IOException e) {
log.info("lost tee: "+ e.toString());
synchronized(tees) {