FileSplitterBase Operator

Hi, I am planning to use below Dag configuration. public void populateDAG(DAG dag, Configuration configuration){ DagInput input = dag.addOperator("Input", new DagInput()); FileSplitterBase splitter = dag.addOperator("Splitter", new FileSplitterBase()); FSSliceReader blockReader

KafkaInputOperator FileNotFoundException

I am getting the same error described here: https://www.mail-archive.com/users@apex.apache.org/msg00533.html I am running Mahlar 3.5.0 with Apex 3.5.0-DT. First I got the zookeeper error. Then I added consumer.zookeeper. Now I am getting: java.io.FileNotFoundException: File does not exist:

Re: Packaging Operator Jars

It is necessary to exclude hadoop jars from the application package. Please see http://docs.datatorrent.com/troubleshooting/#hadoop-dependencies-conflicts Thank you, Vlad On 11/30/16 12:16, Doyle, Austin O. wrote: I was wondering if there was a way to package operator jars with their

Packaging Operator Jars

I was wondering if there was a way to package operator jars with their dependencies and put them into the lib directory for an apa file, and if I were able to do that are there additional files that need to be added apart from the packaged operator jars? I tried with a few different systems

Re: Connection refused exception

Can you check in stram events on the gateway UI, you can select a time range to begin at the start of the application so you can see the series of events that happened in a timeline. Then you will find the first error in that list. You can find stram events in the logical tab to the right for the

Re: Connection refused exception

Hmm, that is strange. I would expect an ERROR in the KafkaInputOperator around 21:01. Please check the earliest killed container log. 2016-11-24 21:01:01,839 [IPC Server handler 4 on 44453] ERROR stram.StreamingContainerManager processOperatorFailure - Initiating container restart after

Re: Connection refused exception

This is the only other stacktrace I could find but it’s dated after the initial cause of failure. 2016-11-24 21:52:24,681 [14/kafkaInputOperator:KafkaInputOperator] ERROR engine.StreamingContainer run - Operator set

Re: error launching in docker sandbox

Ahh, so that’s how you turn on debugging. Thanks for the help! The issue was compiling against java 1.8 and trying to run on 1.7! Thanks! Brandon From: Vlad Rozov Organization: DataTorrent Reply-To: "users@apex.apache.org" Date: Tuesday,