-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/39575/
-----------------------------------------------------------
Review request for samza, Yan Fang and Navina Ramesh.
Bugs: SAMZA-793
https://issues.apache.org/jira/browse/SAMZA-793
Repository: samza
Description
-------
Move rewriter logic to JobRunner so that:
1. It is invoked once
2. It is invoked no matter which job factory is used
Diffs
-----
samza-core/src/main/scala/org/apache/samza/coordinator/JobCoordinator.scala
a926ce639dbf6776ebfb1d885621f4b6bf5f5aa5
samza-core/src/main/scala/org/apache/samza/job/JobRunner.scala
d6109ec4b3eedfe32325c6dc420c6c8bb18eb79b
Diff: https://reviews.apache.org/r/39575/diff/
Testing
-------
Verified via test jobs.
Thanks,
Yi Pan (Data Infrastructure)
