Re: Port issue with running hello-samza on HDP managed by Ambari

2016-02-26 Thread Նարեկ Գալստեան
Hi all, I am trying to do the same thing but am having a different issue. Job fails to successfully register with YARN which is caused by jackson library. It seems that AMbari managed YARN for some reason requires Jackson 1.9.2 and above while Samza job needs Jackson 1.8.5 as JsonClass class use

Re: Port issue with running hello-samza on HDP managed by Ambari

2016-02-26 Thread Jagadish Venkatraman
Hi jack, Glad that you figured this out. On Friday, February 26, 2016, Jack Huang wrote: > Turns out that I need to set the environment variable > > export HADOOP_YARN_HOME=/etc/hadoop > > so that the *run-class.sh *script will pick up the right config file > > Jack Huang > > On Wed, Feb 24, 20

Re: Error when fetching configuration from coordinator

2016-02-26 Thread Jagadish Venkatraman
Are you able to connect to the port on the box? Try doing a wget first. Do you have conflicting versions of Jackson on your classpath? On Friday, February 26, 2016, Jack Huang wrote: > Hi all, > > Still trying to get hello-samza running on our cluster. After I > successfully launched the hello-

Error when fetching configuration from coordinator

2016-02-26 Thread Jack Huang
Hi all, Still trying to get hello-samza running on our cluster. After I successfully launched the hello-samza job with *deploy/samza/bin/run-job.sh --config-factory=org.apache.samza.config.factories.PropertiesConfigFactory --config-path=file://$PWD/deploy/samza/config/wikipedia-feed.properties*

Re: Port issue with running hello-samza on HDP managed by Ambari

2016-02-26 Thread Jack Huang
Turns out that I need to set the environment variable export HADOOP_YARN_HOME=/etc/hadoop so that the *run-class.sh *script will pick up the right config file Jack Huang On Wed, Feb 24, 2016 at 5:56 PM, Jack Huang wrote: > Hi all, > > I am having trouble running the hello-samza example ( > ht

Re: Review Request 41068: SAMZA-813: Add Seek functionality to KeyValueStoreIterator

2016-02-26 Thread Amit Yadav
> On Dec. 8, 2015, 10:55 p.m., Yi Pan (Data Infrastructure) wrote: > > @Amit, thanks for putting up this patch. I have two high-level comments: > > * I would prefer to keep the return type of seek() as an iterator. The > > pattern of the current API looks fine to me: all() and range() gives > >

Re: Review Request 41068: SAMZA-813: Add Seek functionality to KeyValueStoreIterator

2016-02-26 Thread Amit Yadav
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/41068/ --- (Updated Feb. 26, 2016, 6:37 p.m.) Review request for samza and Yi Pan (Data In