Repository: samza Updated Branches: refs/heads/master a0ee94d64 -> 22a1d6f18
SAMZA-805: pass all config to ProcessJob Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/22a1d6f1 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/22a1d6f1 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/22a1d6f1 Branch: refs/heads/master Commit: 22a1d6f18442d2623f76b769497f6c75004af883 Parents: a0ee94d Author: Boris Shkolnik <[email protected]> Authored: Mon Nov 9 11:41:55 2015 -0800 Committer: Yi Pan (Data Infrastructure) <[email protected]> Committed: Mon Nov 9 11:41:55 2015 -0800 ---------------------------------------------------------------------- .../main/scala/org/apache/samza/job/local/ProcessJobFactory.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/22a1d6f1/samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala b/samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala index 4fac154..0792a59 100644 --- a/samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala +++ b/samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala @@ -48,10 +48,9 @@ class ProcessJobFactory extends StreamJobFactory with Logging { } // JobCoordinator is stopped by ProcessJob when it exits coordinator.start - val coordinatorSystemConfig = Util.buildCoordinatorStreamConfig(config) commandBuilder - .setConfig(coordinatorSystemConfig) + .setConfig(config) .setId(0) .setUrl(coordinator.server.getUrl)
