diff --git a/src/java/org/apache/cassandra/streaming/DefaultConnectionFactory.java b/src/java/org/apache/cassandra/streaming/DefaultConnectionFactory.java
index 77ee0f1f00..7e9dfd342c 100644
--- a/src/java/org/apache/cassandra/streaming/DefaultConnectionFactory.java
+++ b/src/java/org/apache/cassandra/streaming/DefaultConnectionFactory.java
@@ -59,11 +59,7 @@ public class DefaultConnectionFactory implements StreamConnectionFactory
             {
                 if (socket != null)
                 {
-                    try
-                    {
-                        socket.close();
-                    }
-                    catch (IOException ignore) {}
+                    socket.close();
                 }
                 if (++attempts >= MAX_CONNECT_ATTEMPTS)
                     throw e;