Brandon,
Is the stacktrace from the app master log or is it from a local mode
run? The exception is raised due to the buffer server termination in one
of the operators containers and I guess that it happens when app master
tries to purge data from the buffer server. Check the operators
containers logs for exceptions/errors unless the application was started
in the local mode. In the later case, try to enable DEBUG level.
Thank you,
Vlad
On 11/29/16 05:54, Feldkamp, Brandon (CONT) 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.
