You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ni...@apache.org on 2016/02/02 01:35:35 UTC
[19/50] [abbrv] samza git commit: SAMZA-805: pass all config to
ProcessJob
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/samza-sql
Commit: 22a1d6f18442d2623f76b769497f6c75004af883
Parents: a0ee94d
Author: Boris Shkolnik <bo...@apache.org>
Authored: Mon Nov 9 11:41:55 2015 -0800
Committer: Yi Pan (Data Infrastructure) <ni...@gmail.com>
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)