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/01/26 20:04:32 UTC
samza git commit: Added some logging to stdout for easier parsing by
tools.
Repository: samza
Updated Branches:
refs/heads/master 75e70e569 -> 9674836f6
Added some logging to stdout for easier parsing by tools.
Author: Prateek Maheshwari <pm...@linkedin.com>
Reviewers: Jagadish<ja...@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 <pm...@linkedin.com>
Authored: Fri Jan 26 12:04:29 2018 -0800
Committer: Jagadish <jv...@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