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
Hi Brandon,
No, it should not. Start apex with - option that will provide more
details in the log.
Thank you,
Vlad
On 11/29/16 14:07, Feldkamp, Brandon (CONT) wrote:
Hello!
I’m trying to launch my app in the docker sandbox but I’m getting an
error. I’m able to launch the app
Hello!
I’m trying to launch my app in the docker sandbox but I’m getting an error. I’m
able to launch the app elsewhere using the datatorrent community edition…would
the difference between apex/datatorrent cause this error?
com.datatorrent.stram.cli.ApexCli$CliException: No applications in
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
I would let some of the kafka experts in the group take a look at this and
suggest further action. If they don't respond I can investigate this
exception further.
Thanks.
On Tue, Nov 29, 2016 at 7:02 AM, Feldkamp, Brandon (CONT) <
brandon.feldk...@capitalone.com> wrote:
> This pops up a little
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
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
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