-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/41106/
-----------------------------------------------------------

(Updated Dec. 9, 2015, 6:41 a.m.)


Review request for samza.


Repository: samza


Description (updated)
-------

1. throws runtime exception if user sets yarn.container.count or 
job.container.count larger than 1 for ProcessJobFactory; 
2. update per Yi's comment


Diffs (updated)
-----

  samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala 
0792a59cb7b042220c8dbfc0713c5ef42e93ab25 

Diff: https://reviews.apache.org/r/41106/diff/


Testing
-------

1. ./gradlew clean build
2. ./gradlew checkstyleMain checkstyleTest
3. manual test open source hello samza and verify that by giving 
yarn.container.count or job.container.count with value greater than 1 for 
ProcessJobFactory, the test will throw the desired exception.


Thanks,

Tao Feng

Reply via email to