Merge branch 'cassandra-3.0' into cassandra-3.X

2016-10-20 10:38:59 -05:00 · 2016-10-20 10:38:59 -05:00 · 26ee16b5f7
parent af1afef564 4ba91cdadd
commit 26ee16b5f7
1 changed files with 1 additions and 5 deletions
--- 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;