|
@@ -313,8 +313,9 @@ class DataXceiver extends DataTransferProtocol.Receiver
|
|
" dest: " + localAddress);
|
|
" dest: " + localAddress);
|
|
|
|
|
|
DataOutputStream replyOut = null; // stream to prev target
|
|
DataOutputStream replyOut = null; // stream to prev target
|
|
- replyOut = new DataOutputStream(
|
|
|
|
- NetUtils.getOutputStream(s, datanode.socketWriteTimeout));
|
|
|
|
|
|
+ replyOut = new DataOutputStream(new BufferedOutputStream(
|
|
|
|
+ NetUtils.getOutputStream(s, datanode.socketWriteTimeout),
|
|
|
|
+ SMALL_BUFFER_SIZE));
|
|
if (datanode.isBlockTokenEnabled) {
|
|
if (datanode.isBlockTokenEnabled) {
|
|
try {
|
|
try {
|
|
datanode.blockTokenSecretManager.checkAccess(blockToken, null, block,
|
|
datanode.blockTokenSecretManager.checkAccess(blockToken, null, block,
|