There was a bug in the 3.5 release, this could be it. We fixed it and put
it into 3.5.1-snapshot. The detail are in JIRA, I don't have access to it
right now.
--
sent from mobile
On Nov 29, 2016 6:02 AM, "Feldkamp, Brandon (CONT)" <
brandon.feldk...@capitalone.com> wrote:
> This pops up a little while later. I’ll have to check to see if I can see
> anything before!
>
>
>
> 016-11-24 21:51:02,443 [main] ERROR stram.StreamingAppMaster main -
> Exiting Application Master
>
> java.lang.NullPointerException
>
> at com.datatorrent.contrib.kafka.
> AbstractKafkaInputOperator.isPartitionRequired(AbstractKafkaInputOperator.
> java:804)
>
> at com.datatorrent.contrib.kafka.
> AbstractKafkaInputOperator.processStats(AbstractKafkaInputOperator.
> java:715)
>
> at com.datatorrent.stram.plan.physical.PhysicalPlan$
> StatsListenerProxy.processStats(PhysicalPlan.java:206)
>
> at com.datatorrent.stram.plan.physical.PhysicalPlan.
> onStatusUpdate(PhysicalPlan.java:1797)
>
> at com.datatorrent.stram.StreamingContainerManager.
> processEvents(StreamingContainerManager.java:1035)
>
> at com.datatorrent.stram.StreamingContainerManager.
> monitorHeartbeat(StreamingContainerManager.java:798)
>
> at com.datatorrent.stram.StreamingAppMasterService.
> execute(StreamingAppMasterService.java:1025)
>
> at com.datatorrent.stram.StreamingAppMasterService.run(
> StreamingAppMasterService.java:647)
>
> at com.datatorrent.stram.StreamingAppMaster.main(
> StreamingAppMaster.java:104)
>
>
>
> *From: *Pramod Immaneni <pra...@datatorrent.com>
> *Reply-To: *"users@apex.apache.org" <users@apex.apache.org>
> *Date: *Tuesday, November 29, 2016 at 8:57 AM
> *To: *"users@apex.apache.org" <users@apex.apache.org>
> *Subject: *Re: Connection refused exception
>
>
>
> 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) <
> brandon.feldk...@capitalone.com> 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.
>
>
>
> ------------------------------
>
> 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.
>
