Satish Duggana created STORM-2197:
-------------------------------------

             Summary: NimbusClient connectins leak due to leakage in 
ThriftClient.
                 Key: STORM-2197
                 URL: https://issues.apache.org/jira/browse/STORM-2197
             Project: Apache Storm
          Issue Type: Bug
    Affects Versions: 2.0.0, 1.x
            Reporter: Satish Duggana
            Assignee: Satish Duggana
            Priority: Critical
             Fix For: 2.0.0, 1.x


Nimbus client connections are not closed when there are errors while connecting 
to nimbus. Created TSocket in ThriftClient should have been closed in case of 
errors.

2016-11-03 08:09:37.766 b.s.s.a.k.KerberosSaslTransportPlugin [ERROR] Client 
failed to open SaslClientTransport to interact with a server during session 
initiation: org.apache.thrift7.transport.TTransportException: Peer indicated 
failure: GSS initiate failed
org.apache.thrift7.transport.TTransportException: Peer indicated failure: GSS 
initiate failed
        at 
org.apache.thrift7.transport.TSaslTransport.receiveSaslMessage(TSaslTransport.java:199)
 ~[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at 
org.apache.thrift7.transport.TSaslTransport.open(TSaslTransport.java:277) 
~[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at 
org.apache.thrift7.transport.TSaslClientTransport.open(TSaslClientTransport.java:37)
 ~[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at 
backtype.storm.security.auth.kerberos.KerberosSaslTransportPlugin$1.run(KerberosSaslTransportPlugin.java:145)
 [storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at 
backtype.storm.security.auth.kerberos.KerberosSaslTransportPlugin$1.run(KerberosSaslTransportPlugin.java:141)
 [storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at java.security.AccessController.doPrivileged(Native Method) 
~[?:1.7.0_60]
        at javax.security.auth.Subject.doAs(Subject.java:415) [?:1.7.0_60]
        at 
backtype.storm.security.auth.kerberos.KerberosSaslTransportPlugin.connect(KerberosSaslTransportPlugin.java:140)
 [storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at 
backtype.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:48)
 [storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at 
backtype.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:103) 
[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at 
backtype.storm.security.auth.ThriftClient.<init>(ThriftClient.java:72) 
[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at backtype.storm.utils.NimbusClient.<init>(NimbusClient.java:106) 
[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at 
backtype.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:82) 
[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at backtype.storm.ui.core$nimbus_summary.invoke(core.clj:584) 
[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at backtype.storm.ui.core$fn__10334.invoke(core.clj:1009) 
[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at compojure.core$make_route$fn__7476.invoke(core.clj:93) 
[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at compojure.core$if_route$fn__7464.invoke(core.clj:39) 
[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at compojure.core$if_method$fn__7457.invoke(core.clj:24) 
[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at compojure.core$routing$fn__7482.invoke(core.clj:106) 
[storm-core-2.4.2-debug-patch.jar:0.10.0-SNAPSHOT]
        at clojure.core$some.invoke(core.clj:2515) [clojure-1.6.0.jar:?]



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to