Brandon, This is not related to kafkaInputOperator talking to Kafka. Do you see any other exceptions in the logs around this exception before or after?
On Tue, Nov 29, 2016 at 6:54 AM, Feldkamp, Brandon (CONT) < [email protected]> wrote: > Hello, > > > > I’m wondering if anyone has seen a similar stack trace before as there > isn’t a lot of info provided. I’m wondering if the connection refused is > from one operator to another or the kafkaInputOperator being unable to > connect to kafka. > > > > Any ideas? Here’s the stacktrace: > > > > 2016-11-24 21:00:51,998 [ProcessWideEventLoop] ERROR netlet.AbstractClient > handleException - Exception in event loop {id=ProcessWideEventLoop, > head=7418, tail=7416, capacity=1024} > > java.net.ConnectException: Connection refused > > at sun.nio.ch.SocketChannelImpl.checkConnect(Native > Method) > > at sun.nio.ch.SocketChannelImpl.finishConnect( > SocketChannelImpl.java:717) > > at com.datatorrent.netlet.DefaultEventLoop. > handleSelectedKey(DefaultEventLoop.java:371) > > at com.datatorrent.netlet.OptimizedEventLoop$ > SelectedSelectionKeySet.forEach(OptimizedEventLoop.java:59) > > at com.datatorrent.netlet.OptimizedEventLoop.runEventLoop( > OptimizedEventLoop.java:192) > > at com.datatorrent.netlet.OptimizedEventLoop.runEventLoop( > OptimizedEventLoop.java:157) > > at com.datatorrent.netlet.DefaultEventLoop.run( > DefaultEventLoop.java:156) > > at java.lang.Thread.run(Thread.java:745) > > 2016-11-24 21:01:01,839 [IPC Server handler 4 on 44453] ERROR > stram.StreamingContainerManager > processOperatorFailure - Initiating container restart after operator > failure PTOperator[id=1,name=kafkaInputOperator] > > 2016-11-24 21:01:01,898 [IPC Server handler 29 on 44453] ERROR > stram.StreamingContainerManager > processOperatorFailure - Initiating container restart after operator > failure PTOperator[id=7,name=kafkaInputOperator] > > 2016-11-24 21:01:32,991 [IPC Server handler 24 on 44453] ERROR > stram.StreamingContainerManager > processOperatorFailure - Initiating container restart after operator > failure PTOperator[id=13,name=kafkaInputOperator] > > 2016-11-24 21:01:44,189 [IPC Server handler 22 on 44453] ERROR > stram.StreamingContainerManager > processOperatorFailure - Initiating container restart after operator > failure PTOperator[id=10,name=kafkaInputOperator] > > 2016-11-24 21:01:44,604 [IPC Server handler 5 on 44453] ERROR > stram.StreamingContainerManager > processOperatorFailure - Initiating container restart after operator > failure PTOperator[id=3,name=kafkaInputOperator] > > 2016-11-24 21:01:44,744 [IPC Server handler 16 on 44453] ERROR > stram.StreamingContainerManager > processOperatorFailure - Initiating container restart after operator > failure PTOperator[id=12,name=kafkaInputOperator] > > Thanks! > > Brandon > > ------------------------------ > > The information contained in this e-mail is confidential and/or > proprietary to Capital One and/or its affiliates and may only be used > solely in performance of work or services for Capital One. The information > transmitted herewith is intended only for use by the individual or entity > to which it is addressed. If the reader of this message is not the intended > recipient, you are hereby notified that any review, retransmission, > dissemination, distribution, copying or other use of, or taking of any > action in reliance upon this information is strictly prohibited. If you > have received this communication in error, please contact the sender and > delete the material from your computer. >
