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. > > > > > > > > > > > > > > > > > >
