tree 247965acadd24eb86e37f1aaace14a1288ae95af
parent bb7d65e2dfff93891c2d79bfeb53c259ec8ccc4f
author Ke Wu <kwu@linkedin.com> 1591146587 -0700
committer mynameborat <bharath.kumarasubramanian@gmail.com> 1591146587 -0700

SAMZA-2537: Fix JobCoordinatorLaunchUtil's execution sequence.

Symptom: A new Samza job fail to deploy.
Cause: For a new samza job, coordinator stream may have not being created yet, therefore, JobCoordinatorLaunchUtil will fail when trying to fetch launch config from coordinator stream.
Changes: Update JobCoordinatorLaunchUtil to create coordinator stream if does not exist before fetching launch config from it.
Tests: None
API Changes: None
Upgrade Instructions: None
Usage Instructions: None 

Author: Ke Wu <kwu@linkedin.com>

Reviewers: mynameborat <bharathkk@apache.org>

Closes #1370 from kw2542/SAMZA-2537