[SAMZA-448] Pass config from JobRunner to JobCoordinator via ConfigStream

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.0
• Fix Version/s: 0.10.0
• Component/s: container
• Assignee: Chris Riccomini
• Reporter: Chris Riccomini
• Created: 28/Oct/14 15:58
• Updated: 29/Apr/15 16:24
• Resolved: 29/Apr/15 16:24

Description

SAMZA-438 modified the AM/local job factories (job coordinator) to pass configuration to SamzaContainer via an HTTP server. This ticket is to modify the other half of the pipeline: the config passing from the JobRunner to the job coordinator to be done via a ConfigStream, rather than an environment variable.

The goal of this ticket is to make the change as transparent as possible. control-job.sh won't be introduced in this ticket. Instead, we'll continue using the ConfigFactories that we have, but pass the resolved config to the coordinator using the ConfigStream rather than the environment variable.

Issue Links

• is related to: SAMZA-458 Close in KafkaSystemProducer should flush all source buffers