|
@@ -1290,7 +1290,7 @@ public class DFSOutputStream extends FSOutputSummer implements Syncable {
|
|
|
final InetSocketAddress isa = NetUtils.createSocketAddr(dnAddr);
|
|
|
final Socket sock = client.socketFactory.createSocket();
|
|
|
final int timeout = client.getDatanodeReadTimeout(length);
|
|
|
- NetUtils.connect(sock, isa, client.getRandomLocalInterfaceAddr(), timeout);
|
|
|
+ NetUtils.connect(sock, isa, client.getRandomLocalInterfaceAddr(), client.getConf().socketTimeout);
|
|
|
sock.setSoTimeout(timeout);
|
|
|
sock.setSendBufferSize(HdfsConstants.DEFAULT_DATA_SOCKET_SIZE);
|
|
|
if(DFSClient.LOG.isDebugEnabled()) {
|