[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14536350#comment-14536350 ] ASF GitHub Bot commented on FLINK-1792: --- Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/553 Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat Fix For: 0.9 As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14534430#comment-14534430 ] ASF GitHub Bot commented on FLINK-1792: --- Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-100220928 LGTM :-) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14534434#comment-14534434 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-100221773 Great. Once this is green, I'll push it to master: https://travis-ci.org/rmetzger/flink/builds/61757934 Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532197#comment-14532197 ] ASF GitHub Bot commented on FLINK-1792: --- Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-99759058 That would be more javaesque than scalaesque. I would rather move the osMXBean retrieval into the map function of the `fetchCPULoad` option. That also solves the problem. ``` fetchCPULoad.map{ method = val osMXBean = method.invoke(osMXBean).asInstanceOf[Double] }.getOrElse(-1) ``` Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532303#comment-14532303 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-99787426 Okay, you are right. Then we can keep it this way. Let me try out your changes one more time, but then I think we are good to merge. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532173#comment-14532173 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-99753925 The code looks much better now. The only thing that makes me still unhappy is the following method ```diff + override def getValue: Double = { +try{ + val osMXBean = ManagementFactory.getOperatingSystemMXBean(). +asInstanceOf[com.sun.management.OperatingSystemMXBean] + fetchCPULoad.map(_.invoke(osMXBean).asInstanceOf[Double]).getOrElse(-1) +} catch { + case t: Throwable = { +LOG.warn(Error retrieving CPU Load through OperatingSystemMXBean, t) +-1 + } +} + } ``` This `getValue()` method is called every 5 seconds to get the metrics from each machine. Users using Java 6 will get the WARN in their log + the exception because the cast to `com.sun.management.OperatingSystemMXBean` will fail every time. I would do the following: If you detect that fetchCpuLoad is null, register a gauge which is always returning -1. Otherwise, register the gauge which is calling fetchCpuLoad. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532392#comment-14532392 ] ASF GitHub Bot commented on FLINK-1792: --- Github user bhatsachin commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-99804027 I have made the change. Thanks a lot Robert and Till. I too am looking forward to contribute more :) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530226#comment-14530226 ] ASF GitHub Bot commented on FLINK-1792: --- Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29744552 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1894,6 +1895,49 @@ object TaskManager { override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) + +// Preprocessing steps for registering cpuLoad +// dummy initialisation +var fetchCPULoad:(Any) = Double = (obj:Any) = -1 + +// define the fetchCPULoad method as per the fetched getProcessCpuLoad method +getMethodToFetchCPULoad() match { + case Some(method) = fetchCPULoad = (obj:Any) = method.asInstanceOf[Method].invoke(obj). +asInstanceOf[Double] + // Log getProcessCpuLoad method not available for Java 6 + case None = LOG.warn(getProcessCpuLoad method not available in the Operating System Bean + +implementation for this Java runtime environment\n + Thread.currentThread().getStackTrace) +} + +metricRegistry.register(cpuLoad, new Gauge[Double] { + override def getValue: Double = { +try{ + val osMXBean = ManagementFactory.getOperatingSystemMXBean(). +asInstanceOf[com.sun.management.OperatingSystemMXBean] + fetchCPULoad(osMXBean) +} catch { + case t: Throwable = { +LOG.warn(Error retrieving CPU Load through OperatingSystemMXBean, t) +-1 + } +} + } +}) metricRegistry } + + /** + * Fetches getProcessCpuLoad method if available in the + * OperatingSystemMXBean implementation else returns None + * @return + */ + private def getMethodToFetchCPULoad(): Option[Method] = { +val methodsList = classOf[com.sun.management.OperatingSystemMXBean].getMethods() +val method = methodsList.filter(_.getName == getProcessCpuLoad) --- End diff -- Shortcut: use `headOption` to obtain result. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530250#comment-14530250 ] ASF GitHub Bot commented on FLINK-1792: --- Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29745454 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1894,6 +1895,52 @@ object TaskManager { override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) +// Preprocessing steps for registering cpuLoad +// fetch the method to get process CPU load +val getCPULoadMethod: Method = getMethodToFetchCPULoad() + +// Log getProcessCpuLoad method not available for Java 6 +if(getCPULoadMethod == null){ + LOG.warn(getProcessCpuLoad method not available in the Operating System Bean + + implementation for this Java runtime environment\n+Thread.currentThread().getStackTrace) +} + +// define the fetchCPULoad method as per the fetched getCPULoadMethod +val fetchCPULoad: (Any) = Double = if (getCPULoadMethod != null) { + (obj: Any) = getCPULoadMethod.invoke(obj).asInstanceOf[Double] +} else { + (obj: Any) = -1 +} + +metricRegistry.register(cpuLoad, new Gauge[Double] { + override def getValue: Double = { +try{ --- End diff -- why not doing: ``` val fetchCPULoad = getMethodToFetchCPULoad() if(fetchCPULoad.isEmpty) { LOG.warn(Java 6 not supported ...) } metricRegistry.register(cpuLoad, new Gauge[Double] { override def getValue(): Double = { try{ val osMXBean = ManagementFactory.getOperatinSystemMXBean() fetchCPULoad.map(_.invoke(osMXBean)) }.getOrElse(-1) } catch { case t: Throwable = { LOG.warn() -1 } } Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14531107#comment-14531107 ] ASF GitHub Bot commented on FLINK-1792: --- Github user bhatsachin commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29786547 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1894,6 +1895,52 @@ object TaskManager { override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) +// Preprocessing steps for registering cpuLoad +// fetch the method to get process CPU load +val getCPULoadMethod: Method = getMethodToFetchCPULoad() + +// Log getProcessCpuLoad method not available for Java 6 +if(getCPULoadMethod == null){ + LOG.warn(getProcessCpuLoad method not available in the Operating System Bean + + implementation for this Java runtime environment\n+Thread.currentThread().getStackTrace) +} + +// define the fetchCPULoad method as per the fetched getCPULoadMethod +val fetchCPULoad: (Any) = Double = if (getCPULoadMethod != null) { + (obj: Any) = getCPULoadMethod.invoke(obj).asInstanceOf[Double] +} else { + (obj: Any) = -1 +} + +metricRegistry.register(cpuLoad, new Gauge[Double] { + override def getValue: Double = { +try{ --- End diff -- Awesome :). These features in Scala are just too good :D Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528354#comment-14528354 ] ASF GitHub Bot commented on FLINK-1792: --- Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-99063892 Thanks for your work @bhatsachin. I had some remarks concerning the Scala style. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528343#comment-14528343 ] ASF GitHub Bot commented on FLINK-1792: --- Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29662675 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1894,6 +1895,52 @@ object TaskManager { override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) + +// Preprocessing steps for registering cpuLoad +// fetch the method to get process CPU load +val getCPULoadMethod: Method = getMethodToFetchCPULoad() + +// define the fetchCPULoad method as per the fetched getCPULoadMethod +// dummy initialisation +var fetchCPULoad:(Any) = Double = (obj:Any) = -1 + +if(getCPULoadMethod != null){ + fetchCPULoad = (obj:Any) = getCPULoadMethod.invoke(obj).asInstanceOf[Double] +} else { + // Log getProcessCpuLoad method not available for Java 6 + LOG.warn(getProcessCpuLoad method not available in the Operating System Bean + +implementation for this Java runtime environment\n + Thread.currentThread().getStackTrace) +} + +metricRegistry.register(cpuLoad, new Gauge[Double] { + override def getValue: Double = { +try{ + val osMXBean = ManagementFactory.getOperatingSystemMXBean(). +asInstanceOf[com.sun.management.OperatingSystemMXBean] + return fetchCPULoad(osMXBean) +} catch { + case t: Throwable = { +LOG.warn(Error retrieving CPU Load through OperatingSystemMXBean, t) +return -1 + } +} + } +}) metricRegistry } + + /** + * Fetches getProcessCpuLoad method if available in the + * OperatingSystemMXBean implementation else returns null + * @return + */ + private def getMethodToFetchCPULoad(): Method = { +val methodsList = classOf[com.sun.management.OperatingSystemMXBean].getMethods() +for(method - methodsList){ --- End diff -- Why not simply using a filter method on methods list? Much more scalaesque. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528703#comment-14528703 ] ASF GitHub Bot commented on FLINK-1792: --- Github user bhatsachin commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29682706 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1894,6 +1895,52 @@ object TaskManager { override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) + +// Preprocessing steps for registering cpuLoad +// fetch the method to get process CPU load +val getCPULoadMethod: Method = getMethodToFetchCPULoad() + +// define the fetchCPULoad method as per the fetched getCPULoadMethod +// dummy initialisation +var fetchCPULoad:(Any) = Double = (obj:Any) = -1 --- End diff -- We need to define fetchCPULoad method as per the object returned by getMethodToFetchCPULoad. val cannot be reassigned and has to be initialised. Hence var has been used to overcome this. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528340#comment-14528340 ] ASF GitHub Bot commented on FLINK-1792: --- Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29662593 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1894,6 +1895,52 @@ object TaskManager { override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) + +// Preprocessing steps for registering cpuLoad +// fetch the method to get process CPU load +val getCPULoadMethod: Method = getMethodToFetchCPULoad() + +// define the fetchCPULoad method as per the fetched getCPULoadMethod +// dummy initialisation +var fetchCPULoad:(Any) = Double = (obj:Any) = -1 + +if(getCPULoadMethod != null){ + fetchCPULoad = (obj:Any) = getCPULoadMethod.invoke(obj).asInstanceOf[Double] +} else { + // Log getProcessCpuLoad method not available for Java 6 + LOG.warn(getProcessCpuLoad method not available in the Operating System Bean + +implementation for this Java runtime environment\n + Thread.currentThread().getStackTrace) +} + +metricRegistry.register(cpuLoad, new Gauge[Double] { + override def getValue: Double = { +try{ + val osMXBean = ManagementFactory.getOperatingSystemMXBean(). +asInstanceOf[com.sun.management.OperatingSystemMXBean] + return fetchCPULoad(osMXBean) --- End diff -- no return statement necessary in Scala Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526425#comment-14526425 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29572469 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -129,6 +130,41 @@ class TaskManager(val connectionInfo: InstanceConnectionInfo, override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) + + // Preprocessing steps for registering cpuLoad + // fetch the method to get process CPU load + val getCPULoadMethod: Method = getMethodToFetchCPULoad() + + // define the fetchCPULoad method as per the fetched getCPULoadMethod + val fetchCPULoad: (Any) = Double = if (getCPULoadMethod != null) { +(obj: Any) = getCPULoadMethod.invoke(obj).asInstanceOf[Double] + } else { +(obj: Any) = { + log.warning(getProcessCpuLoad method not available in the Operating System Bean + --- End diff -- Correct me if i'm wrong, but this log message will appear everytime the cpuLoad is acquired (I think by default 5 seconds). So Java 6 user's will have quite a polluted log Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526428#comment-14526428 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29572528 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -129,6 +130,41 @@ class TaskManager(val connectionInfo: InstanceConnectionInfo, override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) + + // Preprocessing steps for registering cpuLoad + // fetch the method to get process CPU load + val getCPULoadMethod: Method = getMethodToFetchCPULoad() + + // define the fetchCPULoad method as per the fetched getCPULoadMethod + val fetchCPULoad: (Any) = Double = if (getCPULoadMethod != null) { +(obj: Any) = getCPULoadMethod.invoke(obj).asInstanceOf[Double] + } else { +(obj: Any) = { + log.warning(getProcessCpuLoad method not available in the Operating System Bean + +implementation for this Java runtime environment,Thread.currentThread().getStackTrace) + -1 +} + } + + metricRegistry.register(cpuLoad, new Gauge[Double] { +override def getValue: Double = { + try{ +val osMXBean = ManagementFactory.getOperatingSystemMXBean(). + asInstanceOf[com.sun.management.OperatingSystemMXBean] +return fetchCPULoad(osMXBean) + } catch { +case t:Throwable = { + if (t.isInstanceOf[java.lang.ClassCastException]){ +log.warning(Error casting to OperatingSystemMXBean,t) --- End diff -- I think this error will also happen every 5 seconds Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526429#comment-14526429 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29572548 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -129,6 +130,41 @@ class TaskManager(val connectionInfo: InstanceConnectionInfo, override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) + + // Preprocessing steps for registering cpuLoad + // fetch the method to get process CPU load + val getCPULoadMethod: Method = getMethodToFetchCPULoad() + + // define the fetchCPULoad method as per the fetched getCPULoadMethod + val fetchCPULoad: (Any) = Double = if (getCPULoadMethod != null) { +(obj: Any) = getCPULoadMethod.invoke(obj).asInstanceOf[Double] + } else { +(obj: Any) = { + log.warning(getProcessCpuLoad method not available in the Operating System Bean + +implementation for this Java runtime environment,Thread.currentThread().getStackTrace) + -1 +} + } + + metricRegistry.register(cpuLoad, new Gauge[Double] { +override def getValue: Double = { + try{ +val osMXBean = ManagementFactory.getOperatingSystemMXBean(). + asInstanceOf[com.sun.management.OperatingSystemMXBean] +return fetchCPULoad(osMXBean) + } catch { +case t:Throwable = { + if (t.isInstanceOf[java.lang.ClassCastException]){ --- End diff -- I'm not a Scala expert, but I think you can avoid the t.isInstanceOf by matching the exception with the pattern matching (case ..) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526430#comment-14526430 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-98640261 I tried our your changes and looked at the change. - The pull request includes commits which are probably not part of the change. Maybe some merging/rebasing went wrong. Can you try to clean up the branch? Maybe a simple rebase on the current master is sufficient, or you might need to manually cherry-pick your changes on the current master. - The Avg value of the Memory Statistics are not aligned. Probably because the positioning is done using spaces. I think it would be better to use a table there. ![newtm](https://cloud.githubusercontent.com/assets/89049/7450753/ee32659e-f248-11e4-96a6-a31febad4150.png) - The position of the Show Detailed Graph and the Hide Detailed Graph button is not consistent. On is on the bottom of the table cell, the other on the top. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14527617#comment-14527617 ] ASF GitHub Bot commented on FLINK-1792: --- Github user bhatsachin commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29636610 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -129,6 +130,41 @@ class TaskManager(val connectionInfo: InstanceConnectionInfo, override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) + + // Preprocessing steps for registering cpuLoad + // fetch the method to get process CPU load + val getCPULoadMethod: Method = getMethodToFetchCPULoad() + + // define the fetchCPULoad method as per the fetched getCPULoadMethod + val fetchCPULoad: (Any) = Double = if (getCPULoadMethod != null) { +(obj: Any) = getCPULoadMethod.invoke(obj).asInstanceOf[Double] + } else { +(obj: Any) = { + log.warning(getProcessCpuLoad method not available in the Operating System Bean + +implementation for this Java runtime environment,Thread.currentThread().getStackTrace) + -1 +} + } + + metricRegistry.register(cpuLoad, new Gauge[Double] { +override def getValue: Double = { + try{ +val osMXBean = ManagementFactory.getOperatingSystemMXBean(). + asInstanceOf[com.sun.management.OperatingSystemMXBean] +return fetchCPULoad(osMXBean) + } catch { +case t:Throwable = { + if (t.isInstanceOf[java.lang.ClassCastException]){ +log.warning(Error casting to OperatingSystemMXBean,t) --- End diff -- No, this error is not occurring for each heartbeat. This is in case there is a new error while using the getProcessCpuLoad method. I will remove the ClassCastException and make it Throwable so as to catch all types of errors. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514030#comment-14514030 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-96631425 Thank you. I'm trying to find time to review your changes soon. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14508619#comment-14508619 ] ASF GitHub Bot commented on FLINK-1792: --- Github user bhatsachin commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-95480100 The suggested changes have been made Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14481060#comment-14481060 ] ASF GitHub Bot commented on FLINK-1792: --- Github user bhatsachin commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-89987417 The compilation error has been fixed. CPU stats are loading properly for Java 7 and above. For Java 6, the CPU stats column shows Not Available with a popup message explaining why. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396384#comment-14396384 ] ASF GitHub Bot commented on FLINK-1792: --- Github user bhatsachin commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-89848884 Hey Robert, The required changes have been made and are working fine for Java 7 onwards. Using this method, it is not possible to fetch CPU load in Java 6 since there is no implementation of the getProcessCpuLoad method available for OperatingSystemMXBean: http://docs.oracle.com/javase/7/docs/api/java/lang/management/OperatingSystemMXBean.html There is a compilation error due to the unavailable method in jdk 6 and hence the Travis failures. What do you suggest should be the next step? Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14392389#comment-14392389 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-88828965 Please let me know when the PR is ready for review again. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390203#comment-14390203 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r27551487 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -129,6 +129,10 @@ class TaskManager(val connectionInfo: InstanceConnectionInfo, override def getValue: Double = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage() }) + metricRegistry.register(cpuLoad, new Gauge[Double] { +override def getValue: Double = + ManagementFactory.getOperatingSystemMXBean().asInstanceOf[com.sun.management.OperatingSystemMXBean].getProcessCpuLoad() --- End diff -- This cast may fail on some JVM implementations. See http://www.oracle.com/technetwork/java/faq-sun-packages-142232.html Can you surround the metric registration by a try catch block and log a warning in case the cast fails? Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390298#comment-14390298 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-88418659 The memory statistics get pretty big when the chart is enabled as well. Can you hide the string-based statistics when the graph is activated? http://i.imgur.com/VE0p3Dm.png Also, an you make the button appear in the same design as the other buttons on that page? (I think you have to use the bootstrap button classes) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390195#comment-14390195 ] ASF GitHub Bot commented on FLINK-1792: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-88387132 Thank you for the contribution. I'll have a look at the changes. The integration test of your change (https://travis-ci.org/apache/flink/builds/56641563) has failed due to: ``` [INFO] --- scalastyle-maven-plugin:0.5.0:check (default) @ flink-runtime --- error file=/home/travis/build/apache/flink/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala message=File line length exceeds 100 characters line=134 Saving to outputFile=/home/travis/build/apache/flink/flink-runtime/scalastyle-output.xml Processed 45 file(s) ``` To update your pull request, you can just push to the branch this PR is based on. Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14389510#comment-14389510 ] ASF GitHub Bot commented on FLINK-1792: --- GitHub user bhatsachin opened a pull request: https://github.com/apache/flink/pull/553 [FLINK-1792] TM Monitoring: CPU utilization, hide graphs by default and show summary only Added CPU Load %, show/hide button for detailed graph and summary for the metrics You can merge this pull request into a Git repository by running: $ git pull https://github.com/bhatsachin/flink dev-bhatsachin-flink-1792 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/553.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #553 commit 5f5f6a9156a8bbe7dc98a998ade7dc0eab9b2912 Author: bhatsachin bhats...@gmail.com Date: 2015-03-31T08:18:08Z [FLINK-1792] Add processCPULoad in metricsRegistry, add button to show/hide graphs, add summary for metrics Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792 Project: Flink Issue Type: Sub-task Components: Webfrontend Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Sachin Bhat As per https://github.com/apache/flink/pull/421 from FLINK-1501, there are some enhancements to the current monitoring required - Get the CPU utilization in % from each TaskManager process - Remove the metrics graph from the overview and only show the current stats as numbers (cpu load, heap utilization) and add a button to enable the detailed graph. -- This message was sent by Atlassian JIRA (v6.3.4#6332)