Repository: samza Updated Branches: refs/heads/master 75e70e569 -> 9674836f6
Added some logging to stdout for easier parsing by tools. Author: Prateek Maheshwari <pmahe...@linkedin.com> Reviewers: Jagadish<jagad...@apache.org> Closes #414 from prateekm/print-container-info Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/9674836f Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/9674836f Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/9674836f Branch: refs/heads/master Commit: 9674836f603e5566eb74b4b04d8d9b735d402271 Parents: 75e70e5 Author: Prateek Maheshwari <pmahe...@linkedin.com> Authored: Fri Jan 26 12:04:29 2018 -0800 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Fri Jan 26 12:04:29 2018 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/samza/runtime/LocalContainerRunner.java | 2 ++ .../src/main/scala/org/apache/samza/container/SamzaContainer.scala | 1 + samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala | 1 + 3 files changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/9674836f/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java b/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java index 998df8b..79bd568 100644 --- a/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java +++ b/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java @@ -128,8 +128,10 @@ public class LocalContainerRunner extends AbstractApplicationRunner { })); String containerId = System.getenv(ShellCommandConfig.ENV_CONTAINER_ID()); log.info(String.format("Got container ID: %s", containerId)); + System.out.println(String.format("Container ID: %s", containerId)); String coordinatorUrl = System.getenv(ShellCommandConfig.ENV_COORDINATOR_URL()); log.info(String.format("Got coordinator URL: %s", coordinatorUrl)); + System.out.println(String.format("Coordinator URL: %s", coordinatorUrl)); int delay = new Random().nextInt(SamzaContainer.DEFAULT_READ_JOBMODEL_DELAY_MS()) + 1; JobModel jobModel = SamzaContainer.readJobModel(coordinatorUrl, delay); Config config = jobModel.getConfig(); http://git-wip-us.apache.org/repos/asf/samza/blob/9674836f/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala index 5664754..354a8e7 100644 --- a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala +++ b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala @@ -100,6 +100,7 @@ object SamzaContainer extends Logging { info("Setting up Samza container: %s" format containerName) startupLog("Samza container PID: %s" format containerPID) + println("Container PID: %s" format containerPID) startupLog("Using configuration: %s" format config) startupLog("Using container model: %s" format containerModel) http://git-wip-us.apache.org/repos/asf/samza/blob/9674836f/samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala b/samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala index 021ca77..54a5de0 100644 --- a/samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala +++ b/samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala @@ -101,6 +101,7 @@ class JmxServer(requestedPort: Int) extends Logging { jmxServer.start startupLog("Started " + toString) startupLog("If you are tunneling, you might want to try " + toString.replaceAll("localhost", hostname)) + println(s"JMX Server: ${toString.replaceAll("localhost", hostname)}") /** * Get RMI registry port