| commit | bfdea78ba17fb05ee1ad5f457dce542648198f38 | [log] [tgz] |
|---|---|---|
| author | Ariel Shemaiah Rabkin <asrabkin@apache.org> | Mon Apr 12 19:02:02 2010 +0000 |
| committer | Ariel Shemaiah Rabkin <asrabkin@apache.org> | Mon Apr 12 19:02:02 2010 +0000 |
| tree | f53014afda5c40d8eecb817e2d9ecb5f00355cc1 | |
| parent | d6a24ac9fe9aa6ee8c43f4e16216292133cbe14c [diff] |
CHUKWA-466. Fix failing test cases. git-svn-id: https://svn.apache.org/repos/asf/hadoop/chukwa/branches/chukwa-0.4@933366 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java b/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java index 68bd66d..35695e5 100644 --- a/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java +++ b/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java
@@ -153,6 +153,7 @@ out.write(data); } } + out.flush(); } catch(IOException e) { log.info("lost tee: "+ e.toString()); synchronized(tees) {