Hi Anuj, Heartbeat timeout might mean that the operator is not proceeding and is stuck. I can see a "Deploy Request", but nothing after that. Operator setup() might be one place to look at. You can also check https://github.com/apache/apex-malhar/blob/release-3.4/contrib/src/test/java/com/datatorrent/contrib/hbase/HBaseScanOperatorTest.java to see if you are configuring the operator correctly.
You can also try setting the log levels (explained here <http://docs.datatorrent.com/configuration/#adjusting-logging-levels>) to debug to get more information. ~ Bhupesh On Wed, Jul 27, 2016 at 3:23 PM, Bhupesh Chawda <[email protected]> wrote: > 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. >>> > > > >>> > > > >>> > > > >>> > > >>> > >>> >> >> >
