Re: How to pass arguments to a Samza job

2015-04-21 Thread Yan Fang
Hi Jeremy, Currently Samza does not support accepting from command. After SAMZA-655 https://issues.apache.org/jira/browse/SAMZA-655 and SAMZA-348 https://issues.apache.org/jira/browse/SAMZA-348 , you will have other two options - environment variable and stream. *Then How to pass argument from

Re: Review Request 33146: New KeyValueStore Features

2015-04-21 Thread Yi Pan (Data Infrastructure)
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33146/#review81004 ---

Re: Review Request 33146: New KeyValueStore Features

2015-04-21 Thread Yi Pan (Data Infrastructure)
On April 21, 2015, 6:49 p.m., Yi Pan (Data Infrastructure) wrote: samza-kv/src/main/java/org/apache/samza/storage/kv/KeyValueStore.java, line 33 https://reviews.apache.org/r/33146/diff/2/?file=931566#file931566line33 The signature of close() and flush() functions from

Re: How to pass arguments to a Samza job

2015-04-21 Thread Yan Fang
Hi Jeremy, Naveen is correct. You can also pass the argument through --config. I overlooked it. Sorry for the confusion. Cheers, Fang, Yan yanfang...@gmail.com On Tue, Apr 21, 2015 at 2:10 PM, Naveen S navg...@gmail.com wrote: Hey Jeremy, Sorry, it's probably because it's

Re: How to pass arguments to a Samza job

2015-04-21 Thread Naveen S
Hey Jeremy, Sorry, it's probably because it's not documented, but anything with --config will be passed to the property overrides. I just tested it out with hello-samza and it does work. deploy/samza/bin/run-job.sh

Review Request 33409: SAMZA-433 - Rename task to container in AM and container

2015-04-21 Thread Benjamin Fradet
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33409/ --- Review request for samza. Repository: samza Description --- Renamed a