[samza] branch master updated: Added an AM metric for configured container cpu and memory.

[pmaheshwari]

This is an automated email from the ASF dual-hosted git repository.

pmaheshwari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new 7acb405  Added an AM metric for configured container cpu and memory.
7acb405 is described below

commit 7acb4053aaa6ab05236fd16ac03d38e25a9d219e
Author: Prateek Maheshwari <pmaheshw...@apache.org>
AuthorDate: Tue Apr 9 14:24:37 2019 -0700

    Added an AM metric for configured container cpu and memory.
    
    Author: Prateek Maheshwari <pmaheshw...@apache.org>
    
    Reviewers: Ray Matharu <rmath...@linkedin.com>
    
    Closes #989 from prateekm/am-metrics
---
 .../org/apache/samza/metrics/ContainerProcessManagerMetrics.scala  | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala
 
b/samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala
index 93e2604..30c8d1d 100644
--- 
a/samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala
+++ 
b/samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala
@@ -20,7 +20,7 @@
 package org.apache.samza.metrics
 
 import org.apache.samza.clustermanager.SamzaApplicationState
-import org.apache.samza.config.Config
+import org.apache.samza.config.{ClusterManagerConfig, Config}
 import org.apache.samza.config.MetricsConfig.Config2Metrics
 import org.apache.samza.util.Logging
 import org.apache.samza.util.MetricsReporterLoader
@@ -43,6 +43,8 @@ class ContainerProcessManagerMetrics(
 
   val jvm = new JvmMetrics(registry)
   val reporters = MetricsReporterLoader.getMetricsReporters(config, 
ContainerProcessManagerMetrics.sourceName).asScala
+  val clusterManagerConfig = new ClusterManagerConfig(config)
+
   
reporters.values.foreach(_.register(ContainerProcessManagerMetrics.sourceName, 
registry))
 
    def start() {
@@ -73,6 +75,9 @@ class ContainerProcessManagerMetrics(
      val mFailoversToAnyHost = newGauge("failovers-to-any-host", () => 
state.failoversToAnyHost.get())
      val mFailoversToStandby = newGauge("failovers-to-standby", () => 
state.failoversToStandby.get())
 
+     val mContainerMemoryMb = newGauge("container-memory-mb", () => 
clusterManagerConfig.getContainerMemoryMb)
+     val mContainerCpuCores = newGauge("container-cpu-cores", () => 
clusterManagerConfig.getNumCores)
+
     jvm.start
     reporters.values.foreach(_.start)
   }