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