Re: A few questions about the Kafka 0.9 operator

You can also have a look at this blog and linked example that specifically covers exactly-once with input from Kafka: https://www.datatorrent.com/blog/end-to-end-exactly-once-with-apache-apex/ On Tue, Jun 14, 2016 at 2:47 PM, Thomas Weise wrote: > See response below: >

Re: A few questions about the Kafka 0.9 operator

See response below: On Tue, Jun 14, 2016 at 12:41 PM, Ananth Gundabattula < agundabatt...@gmail.com> wrote: > Hello Siyuan/All, > > I have a couple of questions regarding the Kafka 0.9 operator. Could you > please help me in understanding this operator a bit better? > > >- As stated in >

A few questions about the Kafka 0.9 operator

Hello Siyuan/All, I have a couple of questions regarding the Kafka 0.9 operator. Could you please help me in understanding this operator a bit better? - As stated in http://www.slideshare.net/ApacheApex/apache-apex-kafka-input-operator , kafka 0.9 operator stores it "check-pointed

Re: Containers Not getting Allocated.

There is one known issue, https://issues.apache.org/jira/browse/APEXCORE-471 On Tue, Jun 14, 2016 at 7:58 AM Munagala Ramanath wrote: > Could you take a look at the YARN logs ? > > Ram > > On Tue, Jun 14, 2016 at 5:43 AM, Shubham Pathak > wrote:

Re: Containers Not getting Allocated.

Hi, What are YARN memory configurations? This should help you tune those configurations: http://www.cloudera.com/documentation/enterprise/5-5-x/topics/cdh_ig_yarn_tuning.html Thanks, Aniruddha On Tue, Jun 14, 2016 at 6:13 PM, Shubham Pathak wrote: > Hello, > > I