Re: Container failure without relaunch

It may also help to enable DEBUG level logging for com.datatorrent.* once the issue is reproduced again and check activity in the application master logs. Thank you, Vlad On 5/30/17 10:41, Sandesh Hegde wrote: When that issue happens, please check the free resource(CPU and memory) available

Re: AvroToPojo Operator doesn't recover after failure and keeps throwing Kryo exception

Hi Sandesh. this worked as expected. Regards Vivek -- View this message in context: http://apache-apex-users-list.78494.x6.nabble.com/AvroToPojo-Operator-doesn-t-recover-after-failure-and-keeps-throwing-Kryo-exception-tp1660p1667.html Sent from the Apache Apex Users list mailing list archive

Re: Apex and RabbitMQ problems with the input operator

Both com.datatorrent.contrib.helper and com.datatorrent.lib.helper are under the test directory under malhar-contrib and malhar-library respectively. You may need to build these jars yourself with test scope to include these packages. On Wed, May 31, 2017 at 9:39 AM, wrote: >

Apex and RabbitMQ problems with the input operator

Hello, (mea culpa for messing up the headline the first time) I'm currently trying to get the apex-malhar rabbitmq running. But I'm at a complete loss, while the examples are running fine I don't even get the RabbitMQInputOperatorTest.java to run. * * First it couldn't find the rabbitmq-client