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

Review request for samza.


Repository: samza


Description
-------

Moved the producer before starting the task. This will allow KV to be 
initialized in the init method.


Diffs
-----

  samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala 
87fcf589b10fd952df630d498c645159ed381739 

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


Testing
-------

- All unit tests pass
- All Integration tests pass
- Torture tests in running (no issues so far..)


Thanks,

Naveen Somasundaram

Reply via email to