Re: Review Request 35445: SAMZA-693: Very basic HDFS Producer service for Samza

2015-08-06 Thread Eli Reisman
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35445/ --- (Updated Aug. 6, 2015, 11:23 p.m.) Review request for samza. Repository: samz

Re: Kill All Jobs

2015-08-06 Thread Shekar Tippur
Thanks Jordi. This really helps. - Shekar On Thu, Aug 6, 2015 at 12:21 AM, Jordi Blasi Uribarri wrote: > Hi, > > As a little present (and I know this is not the way to get the code in the > project, but I am new to this sharing). I just made a simple script to kill > all the jobs running in Sam

I have a problem with Samza and YARN

2015-08-06 Thread Aleksandar Pejakovic
Hi all, I have problem with YARN 2.6.0. For this patch: https://issues.apache.org/jira/browse/SAMZA-563 i tried to change samza with hello-samza to work on YARN 2.6.0. All tests in samza pass nicely but when i try to run bin/grid bootstrap from hello-samza there are some problems with startin

Re: Review Request 36903: SAMZA-744: shutdown stores before shutdown producers

2015-08-06 Thread Yi Pan (Data Infrastructure)
> On Aug. 5, 2015, 7:48 a.m., Yan Fang wrote: > > samza-test/src/test/scala/org/apache/samza/test/integration/StreamTaskTest.scala, > > lines 47-49 > > > > > > we need to remove the author information. :) And maybe a

Re: Review Request 36903: SAMZA-744: shutdown stores before shutdown producers

2015-08-06 Thread Yi Pan (Data Infrastructure)
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36903/ --- (Updated Aug. 6, 2015, 11:24 a.m.) Review request for samza, Yan Fang, Chinmay

RE: Missing a change log offset for SystemStreamPartition

2015-08-06 Thread Jordi Blasi Uribarri
I changed the job name and the store name. I was defining two different stores and in case that was the problem, I also eliminated the second one. I am getting the same exception. Exception in thread "main" org.apache.samza.SamzaException: Missing a change log offset for SystemStreamPartition [

Re: Review Request 37039: SAMZA-748 Coordinator URL always 127.0.0.1

2015-08-06 Thread József Márton Jung
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/37039/ --- (Updated Aug. 6, 2015, 8:11 a.m.) Review request for samza. Changes ---

Kill All Jobs

2015-08-06 Thread Jordi Blasi Uribarri
Hi, As a little present (and I know this is not the way to get the code in the project, but I am new to this sharing). I just made a simple script to kill all the jobs running in Samza. It is supposed to live with kill-yarn-job.sh in the bin folder. It shares me time, so maybe someone finds it

Re: Review Request 37039: SAMZA-748 Coordinator URL always 127.0.0.1

2015-08-06 Thread Yan Fang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/37039/#review94370 --- samza-core/src/main/scala/org/apache/samza/util/Util.scala (line 30