Hey sgg, Yes, you can change the container count to any number where 1 <= container count <= max input partitions. The configuration to make this change is:
yarn.container.count=1 All config in Samza is resolved at job start time, and remains immutable for the remainder of the job execution, so you can't dynamically change the container count. You need to restart the Samza job to update the configuration. Cheers, Chris On 12/11/13 8:47 AM, "sgg" <[email protected]> wrote: >A part of the documentation >(http://samza.incubator.apache.org/learn/documentation/0.7.0/container/tas >k-runner.html) suggests it ?might? be possible to change the number of >containers allocated to a job: > "Your Samza job might be unable to keep up with only one container, so >you ask for a second YARN container to put some of the StreamTask >partitions" > >How does one ask for a second YARN container? Is it a matter of stoping >the job, changing the configuration and starting a new job? or is there >some way to do this without starting a job? > >sgg
