From 8829f97344cd9a7a9cfdee4db3d55a2635ff1f31 Mon Sep 17 00:00:00 2001 From: zentol Date: Wed, 15 Jun 2016 12:30:22 +0200 Subject: [PATCH] [FLINK-4057] Slots/regTaskManagers/numJobs --- .../flink/runtime/jobmanager/JobManager.scala | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala index 314977ab485..852b238e2fc 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala @@ -1758,6 +1758,19 @@ class JobManager( } private def instantiateMetrics(jobManagerMetricGroup: MetricGroup) : Unit = { + jobManagerMetricGroup.gauge[Long, Gauge[Long]]("taskSlotsAvailable", new Gauge[Long] { + override def getValue: Long = JobManager.this.instanceManager.getNumberOfAvailableSlots + }) + jobManagerMetricGroup.gauge[Long, Gauge[Long]]("taskSlotsTotal", new Gauge[Long] { + override def getValue: Long = JobManager.this.instanceManager.getTotalNumberOfSlots + }) + jobManagerMetricGroup.gauge[Long, Gauge[Long]]("numRegisteredTaskManagers", new Gauge[Long] { + override def getValue: Long + = JobManager.this.instanceManager.getNumberOfRegisteredTaskManagers + }) + jobManagerMetricGroup.gauge[Long, Gauge[Long]]("numRunningJobs", new Gauge[Long] { + override def getValue: Long = JobManager.this.currentJobs.size + }) instantiateStatusMetrics(jobManagerMetricGroup) } -- GitLab