Exception with API

2016-12-12 Thread Feldkamp, Brandon (CONT)
Hello, I’m getting the below exception when trying to use the API to upload an app. Any idea what it means? I’ve gotten this to work previously. 2016-12-12 10:18:59,893 ERROR com.datatorrent.gateway.y: Command failed and returned this in stderr: 2016-12-12 10:18:59,894 INFO

Re: Connection refused exception

2016-11-30 Thread Feldkamp, Brandon (CONT)
he 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 connect

Re: error launching in docker sandbox

2016-11-30 Thread Feldkamp, Brandon (CONT)
.org> Date: Tuesday, November 29, 2016 at 9:08 PM To: "users@apex.apache.org" <users@apex.apache.org> Subject: Re: error launching in docker sandbox 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

error launching in docker sandbox

2016-11-29 Thread Feldkamp, Brandon (CONT)
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

Re: Connection refused exception

2016-11-29 Thread Feldkamp, Brandon (CONT)
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.fel

Connection refused exception

2016-11-29 Thread Feldkamp, Brandon (CONT)
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

Re: error with AbstractFileOutputOperator rolling files from tmp

2016-11-10 Thread Feldkamp, Brandon (CONT)
cationId to the last set value of filePath causing applicationId appended twice. - Tushar. On Thu, Nov 10, 2016 at 7:50 AM, Feldkamp, Brandon (CONT) <brandon.feldk...@capitalone.com> wrote: > Cut off part of the stack trace > >

error with AbstractFileOutputOperator rolling files from tmp

2016-11-09 Thread Feldkamp, Brandon (CONT)
Hello, I’m seeing this error: hdfs://.../output/application_1478724068939_0002/application_1478724068939_0002/output.txt.0.1478726546727.tmp at org.apache.hadoop.hdfs.DistributedFileSystem$19.doCall(DistributedFileSystem.java:1219) at

In need of example of output to S3

2016-08-24 Thread Feldkamp, Brandon (CONT)
Hello, I’m in search for an example of outputting data to S3. I was reading documentation here http://docs.datatorrent.com/apex_malhar/ which makes it sound like this is already supported but I’m having trouble finding a good example to get started with. Thanks in advance! Brandon