[SAMZA-2537] Fix JobCoordinatorLaunchUtil's execution sequence.

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5
• Flags: Patch
• Assignee: Unassigned
• Reporter: Ke Wu
• Created: 01/Jun/20 21:50
• Updated: 03/Jun/20 01:12
• Resolved: 03/Jun/20 01:12

Description

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 

Issue Links

• links to: Pull request 1370