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) > <[email protected]> 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] >
