Stop requiring processor.id configuration in PassThroughJC
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/b027b438 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/b027b438 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/b027b438 Branch: refs/heads/master Commit: b027b438479153e1ed73ad3b1ecf9de148af8d2b Parents: 473b6c3 Author: Jagadish <jvenkatra...@linkedin.com> Authored: Mon Oct 22 22:09:20 2018 -0700 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Mon Oct 22 22:09:20 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/b027b438/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 737ac3e..7522106 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 = Integer.toString(config.getInt(JobConfig.PROCESSOR_ID())); + String containerId = config.get(JobConfig.PROCESSOR_ID()); /** TODO: Locality Manager seems to be required in JC for reading locality info and grouping tasks intelligently and also,
