alnzng opened a new pull request #1299: SAMZA-2477: JobModel isn't updated with latest "task.inputs" if enabled regex topic rewriter URL: https://github.com/apache/samza/pull/1299 ### Symptom JobModelManager provides readJobModel() function to let `JobCoordinator`, `ClusterBasedJboCoordinator` and etc know 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. ### Cause `JobModelManager.readJobModel()` uses the original config instead of the updated config to build `JobModel`. ### Changes Use updated config to build final `JobModel`. ### Tests - [ ] All unit tests and integration tests are passed ### API Changes None ### Upgrade Instructions None ### Usage Instructions None
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
