You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by "Nithin Uppalapati (BLOOMBERG/ 731 LEX)" <nu...@bloomberg.net> on 2020/02/18 20:07:57 UTC

TTransportException during shutdown of topology

Hi,

Getting the following errors during shutdown of the topology, can I know what could be the reason?

2020-02-15 17:23:06,190 ERROR TThreadPoolServer [pool-14-thread-35] Thrift error occurred during processing of message.
org.apache.storm.thrift.transport.TTransportException: null
        at org.apache.storm.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.transport.TTransport.readAll(TTransport.java:86) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.transport.TSaslTransport.readLength(TSaslTransport.java:374) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.transport.TSaslTransport.readFrame(TSaslTransport.java:451) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.transport.TSaslTransport.read(TSaslTransport.java:433) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.transport.TSaslServerTransport.read(TSaslServerTransport.java:43) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.transport.TTransport.readAll(TTransport.java:86) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:425) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:321) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:225) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.TBaseProcessor.process(TBaseProcessor.java:27) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.security.auth.SaslTransportPlugin$TUGIWrapProcessor.process(SaslTransportPlugin.java:145) ~[storm-core-1.2.3.jar:1.2.3]
        at org.apache.storm.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:310) ~[storm-core-1.2.3.jar:1.2.3]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_172]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_172]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_172]

Re: TTransportException during shutdown of topology

Posted by Ethan Li <et...@gmail.com>.

Hi

It’s hard to know without more logs. But it could be other workers which connected to this worker shut down abruptly and the connection was closed unexpectedly, according to the code at https://github.com/apache/thrift/blob/0.12.0/lib/java/src/org/apache/thrift/transport/TIOStreamTransport.java#L132 <https://github.com/apache/thrift/blob/0.12.0/lib/java/src/org/apache/thrift/transport/TIOStreamTransport.java#L132> 

Best,
Ethan

> On Feb 18, 2020, at 2:07 PM, Nithin Uppalapati (BLOOMBERG/ 731 LEX) <nu...@bloomberg.net> wrote:
> 
> Hi,
> 
> Getting the following errors during shutdown of the topology, can I know what could be the reason?
> 
> 2020-02-15 17:23:06,190 ERROR TThreadPoolServer [pool-14-thread-35] Thrift error occurred during processing of message.
> org.apache.storm.thrift.transport.TTransportException: null
>         at org.apache.storm.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.transport.TTransport.readAll(TTransport.java:86) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.transport.TSaslTransport.readLength(TSaslTransport.java:374) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.transport.TSaslTransport.readFrame(TSaslTransport.java:451) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.transport.TSaslTransport.read(TSaslTransport.java:433) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.transport.TSaslServerTransport.read(TSaslServerTransport.java:43) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.transport.TTransport.readAll(TTransport.java:86) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:425) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:321) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:225) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.TBaseProcessor.process(TBaseProcessor.java:27) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.security.auth.SaslTransportPlugin$TUGIWrapProcessor.process(SaslTransportPlugin.java:145) ~[storm-core-1.2.3.jar:1.2.3]
>         at org.apache.storm.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:310) ~[storm-core-1.2.3.jar:1.2.3]
>         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_172]
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_172]
>         at java.lang.Thread.run(Thread.java:748) [?:1.8.0_172]
>