Ke Wu created SAMZA-2381:
----------------------------
Summary: Refactor JobRunner#run
Key: SAMZA-2381
URL: https://issues.apache.org/jira/browse/SAMZA-2381
Project: Samza
Issue Type: Improvement
Reporter: Ke Wu
The existing JobRunner#run is a huge method which composes multiple parts,
persisting config in coordinator stream, creation of diagnostics stream and
submitting the job.
Split them into smaller methods to improve readability as well as for re-use
purpose, especially when we move planning to AM, then we need to separate
methods.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
