[SAMZA-2477] JobModel isn't updated with latest "task.inputs" if enabled regex topic rewriter

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5
• Assignee: Alan Zhang
• Reporter: Alan Zhang
• Created: 28/Feb/20 19:17
• Updated: 27/May/20 03:53
• Resolved: 16/Mar/20 23:16

Description

JobModelManager provides readJobModel() function to let JobCoordinator, ClusterBasedJboCoordinator and etc notice the latest JobModel information.

If the users enable regex topic rewriter in their config, readJobModel() function will dynamically load the latest Kafka topic list and generate new TaskModel with new topic partition mappings.

However, it doesn't update the `task.inputs` in JobModel's Config. So other services depend on `task.inputs` information will still see stale data.

Issue Links

• links to: GitHub Pull Request #1299