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

(Updated May 30, 2015, 11:49 p.m.)


Review request for samza, Chris Riccomini, Guozhang Wang, Yi Pan (Data 
Infrastructure), and Naveen Somasundaram.


Bugs: SAMZA-618
    https://issues.apache.org/jira/browse/SAMZA-618


Repository: samza


Description
-------

Adding Locality Manager file


reading in JC and writing from containers


After SAMZA-686 changes


Fixing stylechecks


Correcting when coordinator system accessors start & stop


Corrected documentation


Diffs (updated)
-----

  checkstyle/import-control.xml 5f8e103a2e43f96518b20de1c7cbd84e0af24842 
  samza-core/src/main/java/org/apache/samza/container/LocalityManager.java 
PRE-CREATION 
  
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamMessage.java
 0988dedc3e8ad1b4080fb89dfff7c6f95fba8b67 
  samza-core/src/main/java/org/apache/samza/job/model/JobModel.java 
fa113e12080384586b329c82133bc0601b855ae5 
  samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala 
50e53fbcb55c4e9176bf29217a341b195c96d762 
  samza-core/src/main/scala/org/apache/samza/coordinator/JobCoordinator.scala 
5b43b58a851c363846b433ebd589ce6dd5c5c932 
  samza-core/src/test/scala/org/apache/samza/container/TestSamzaContainer.scala 
a7fa0857d1243f5a24e4550a39ee230fbd7705bb 

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


Testing
-------

Used a sample job to test it locally and also, by setting up YARN on 3 
machines. 
Verified that the message is correctly written and consumed from the 
Coordinator Stream


Thanks,

Navina Ramesh

Reply via email to