You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2018/11/27 09:48:32 UTC

[25/50] samza git commit: Revert changes to PassthroughJC

Revert changes to PassthroughJC


Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/456e697d
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/456e697d
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/456e697d

Branch: refs/heads/master
Commit: 456e697d8034099f032361268f3768b085395696
Parents: d8336be
Author: Jagadish <jv...@linkedin.com>
Authored: Tue Oct 23 23:38:13 2018 -0700
Committer: Jagadish <jv...@linkedin.com>
Committed: Tue Oct 23 23:38:13 2018 -0700

----------------------------------------------------------------------
 .../org/apache/samza/standalone/PassthroughJobCoordinator.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/samza/blob/456e697d/samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java
----------------------------------------------------------------------
diff --git a/samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java b/samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java
index 7522106..737ac3e 100644
--- a/samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java
+++ b/samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java
@@ -119,7 +119,7 @@ public class PassthroughJobCoordinator implements JobCoordinator {
     SystemAdmins systemAdmins = new SystemAdmins(config);
     StreamMetadataCache streamMetadataCache = new StreamMetadataCache(systemAdmins, 5000, SystemClock.instance());
     systemAdmins.start();
-    String containerId = config.get(JobConfig.PROCESSOR_ID());
+    String containerId = Integer.toString(config.getInt(JobConfig.PROCESSOR_ID()));
 
     /** TODO:
      Locality Manager seems to be required in JC for reading locality info and grouping tasks intelligently and also,