Author: cutting
Date: Mon Mar 13 15:17:09 2006
New Revision: 385696
URL: http://svn.apache.org/viewcvs?rev=385696&view=rev
Log:
Fix for HADOOP-78. Stream buffering was mistakenly disabled in writes
by the RPC client. Identified & fixed by Owen O'Malley.
Modified:
lucene/hadoop/trunk/src/java/org/apache/hadoop/ipc/Client.java
Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/ipc/Client.java
URL: http://svn.apache.org/viewcvs/lucene/hadoop/trunk/src/java/org/apache/hadoop/ipc/Client.java?rev=385696&r1=385695&r2=385696&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/ipc/Client.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/ipc/Client.java Mon Mar 13 15:17:09 2006
@@ -126,7 +126,7 @@
(new BufferedOutputStream
(new FilterOutputStream(socket.getOutputStream()) {
public void write(byte[] buf, int o, int len) throws IOException {
- super.write(buf, o, len);
+ out.write(buf, o, len);
if (writingCall != null) {
writingCall.touch();
}
|