diff --git a/astyanax-thrift/src/main/java/com/netflix/astyanax/thrift/ThriftSyncConnectionFactoryImpl.java b/astyanax-thrift/src/main/java/com/netflix/astyanax/thrift/ThriftSyncConnectionFactoryImpl.java index 31c9474d4..79538b60b 100644 --- a/astyanax-thrift/src/main/java/com/netflix/astyanax/thrift/ThriftSyncConnectionFactoryImpl.java +++ b/astyanax-thrift/src/main/java/com/netflix/astyanax/thrift/ThriftSyncConnectionFactoryImpl.java @@ -187,10 +187,10 @@ public void open() throws ConnectionException { socket.getSocket().setKeepAlive(true); socket.getSocket().setSoLinger(false, 0); - setTimeout(cpConfig.getSocketTimeout()); transport = new TFramedTransport(socket); if(!transport.isOpen()) transport.open(); + setTimeout(cpConfig.getSocketTimeout()); cassandraClient = new Cassandra.Client(new TBinaryProtocol.Factory().getProtocol(transport)); monitor.incConnectionCreated(getHost());