Blob Blame History Raw
--- cassandra-cassandra-3.5/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java	2016-04-09 06:22:00.000000000 +0200
+++ src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java	2016-05-31 15:19:09.777021914 +0200
@@ -188,9 +188,9 @@
             TProtocol inputProtocol = null;
             TProtocol outputProtocol = null;
             SocketAddress socket = null;
-            try (TTransport inputTransport = inputTransportFactory_.getTransport(client_);
-                 TTransport outputTransport = outputTransportFactory_.getTransport(client_))
-            {
+	    TTransport inputTransport = inputTransportFactory_.getTransport(client_);
+            TTransport outputTransport = outputTransportFactory_.getTransport(client_);
+            try {
                 socket = ((TCustomSocket) client_).getSocket().getRemoteSocketAddress();
                 ThriftSessionManager.instance.setCurrentSocket(socket);
                 processor = processorFactory_.getProcessor(client_);
@@ -226,7 +226,10 @@
             {
                 if (socket != null)
                     ThriftSessionManager.instance.connectionComplete(socket);
-
+		if (inputTransport != null)
+           	    inputTransport.close();
+		if (outputTransport != null)
+           	    outputTransport.close();
                 activeClients.decrementAndGet();
             }
         }