Hi Anuj,

I don't see an attachment.
If you are facing issues can you create a JIRA issue here
<https://issues.apache.org/jira/browse/APEXMALHAR> and attach the logs?

~ Bhupesh

On Wed, Jul 27, 2016 at 3:05 PM, ANUJ THAKWANI <[email protected]>
wrote:

> Hi,
>
> Attaching full Operator log for reference.
>
> Operator being used is HbaseScanOperator and its abstract operationScan()
> & getTuple() method have been implemented.
>
>
>
> On Wed, Jul 27, 2016 at 2:55 PM, Bhupesh Chawda <[email protected]>
> wrote:
>
>> Thanks Anuj.
>>
>> The attachment seems to be for the App master. Can you please check if
>> there is any information in the container corresponding to the operator?
>> The operator log will usually have something like "INFO
>> com.datatorrent.stram.engine.StreamingContainer: Child starting"  at the
>> beginning.
>>
>> Is "HBasePOJOInputOperator" the one you are using?
>>
>> ~ Bhupesh
>>
>>
>> On Wed, Jul 27, 2016 at 2:32 PM, ANUJ THAKWANI <[email protected]>
>> wrote:
>>
>> > Hi Bhupesh,
>> >
>> > Please find comments inline
>> >
>> > Can you also share the HBase operator logs? Also, which version of
>> Malhar
>> > are you using?
>> > dt.log shared in first mail is the log file of hbase operator . Malhar
>> > version is 3.4.0
>> >
>> > Is the operator getting killed immediately, or does it at least input
>> some
>> > values and then get killed?
>> >
>> > Operator gets killed after 30 sec(heartbeat timeout) without processing
>> any
>> > values. No exception is thrown when the operator is killed by AM.
>> >
>> > On Wed, Jul 27, 2016 at 1:21 PM, Bhupesh Chawda <[email protected]>
>> > wrote:
>> >
>> > > Hi Anuj,
>> > >
>> > > Can you also share the HBase operator logs? Also, which version of
>> Malhar
>> > > are you using?
>> > > Is the operator getting killed immediately, or does it at least input
>> > some
>> > > values and then get killed?
>> > >
>> > > Thanks
>> > > ~ Bhupesh
>> > >
>> > > On Wed, Jul 27, 2016 at 12:51 PM, ANUJ THAKWANI <
>> [email protected]
>> > >
>> > > wrote:
>> > >
>> > > > Hi,
>> > > >
>> > > > I am trying to input values from Hbase using HbaseScan operator but
>> > > > getting container killed messages repeatedly. Seems like heart beat
>> is
>> > > > getting timed out and window of HbaseOperator is not moving.
>> > > >
>> > > > Please let me know what should i do to get this fixed.
>> > > >
>> > > > Attaching log for reference.
>> > > >
>> > > >
>> > > >
>> > >
>> >
>>
>
>

Reply via email to