Alan Zhang created SAMZA-2477:
---------------------------------
Summary: JobModel isn't updated with latest "task.inputs" if
enabled regex topic rewriter
Key: SAMZA-2477
URL: https://issues.apache.org/jira/browse/SAMZA-2477
Project: Samza
Issue Type: Bug
Reporter: Alan Zhang
Assignee: Alan Zhang
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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
