> On Dec. 8, 2015, 11:20 p.m., Yi Pan (Data Infrastructure) wrote: > > samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala, > > line 54 > > <https://reviews.apache.org/r/41106/diff/1/?file=1156584#file1156584line54> > > > > It would be better to use JobConfig.getContainerCount() instead of > > repeating the code here. The following line does the trick for you to use > > config object as JobConfig object: > > > > import org.apache.samza.config.JobConfig.Config2Job
Update rb per comment - Tao ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/41106/#review109428 ----------------------------------------------------------- On Dec. 9, 2015, 6:41 a.m., Tao Feng wrote: > > ----------------------------------------------------------- > 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 > ------- > > 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 > ----- > > > 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 > >
