gt;
>>>
>>> Hadoop version : hadoop-2.7.0 (Mapr distribution 5.1)
>>>
>>>
>>>
>>> Thanks,
>>>
>>> Srinivas
>>>
>>>
>>>
>>> *From:* Ashwin Chandra Putta [mailto:ashwinchand...@gmail.com]
>>
gt;>
>> Hadoop version : hadoop-2.7.0 (Mapr distribution 5.1)
>>
>>
>>
>> Thanks,
>>
>> Srinivas
>>
>>
>>
>> *From:* Ashwin Chandra Putta [mailto:ashwinchand...@gmail.com]
>> *Sent:* Wednesday, October 19, 2016 3:05 PM
>>
;
>
>
> *From:* Ashwin Chandra Putta [mailto:ashwinchand...@gmail.com]
> *Sent:* Wednesday, October 19, 2016 2:40 PM
> *To:* users@apex.apache.org
> *Subject:* Re: Retry functionality in Datatorrent
>
>
>
> Jaspal,
>
>
>
> Ensure that the app package is not inc
lt;mailto:users@apex.apache.org>
Subject: Re: Retry functionality in Datatorrent
Jaspal,
Ensure that the app package is not including any hadoop jars as dependencies.
Check target/deps/
You can exclude those dependencies in the maven pom file.
Regards,
Ashwin.
On Wed, Oct 19, 2016 at 12:0
wrote:
> We have a Hbase client dependency and do not have any Hadoop dependencies
> in project.
>
>
>
> *From:* Ashwin Chandra Putta [mailto:ashwinchand...@gmail.com]
> *Sent:* Wednesday, October 19, 2016 2:40 PM
> *To:* users@apex.apache.org
> *Subject:* Re: R
We have a Hbase client dependency and do not have any Hadoop dependencies in
project.
From: Ashwin Chandra Putta [mailto:ashwinchand...@gmail.com]
Sent: Wednesday, October 19, 2016 2:40 PM
To: users@apex.apache.org
Subject: Re: Retry functionality in Datatorrent
Jaspal,
Ensure that the app
Jaspal,
Ensure that the app package is not including any hadoop jars as
dependencies. Check target/deps/
You can exclude those dependencies in the maven pom file.
Regards,
Ashwin.
On Wed, Oct 19, 2016 at 12:09 PM, Jaspal Singh
wrote:
> Hi Ashwin, That's correct flow !!
>
> Team - ANother thin
Hi Ashwin, That's correct flow !!
Team - ANother thing we are receiving below exception in the logs and
application is FAILING when we are trying to make an update to HBase table.
Any idea what could be the reason ?
Container: container_e32_1476503307399_0172_02_01 on
dbslt0079.uhc.com_8091
Jaspal,
If I understand this correctly, the flow looks like this.
REST API --> Kafka topic --> Apex Kafka Input Operator.
If this is the flow, then the kafka input operator should be reading
messages from Kafka without losing them. There is no retry attempts
necessary.
Let me know if the unders
Hi Team,
We are pushing messages from Kafka to Datatorrent application using REST
API service as a producer. If say due to some issue with the service the
message couldn't be pushed/processed so we want to "retry it for n times"
before it is dropped.
Is there any retry functionality built within
10 matches
Mail list logo
