You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celeborn.apache.org by an...@apache.org on 2023/02/06 06:03:00 UTC

[incubator-celeborn] branch main updated: [CELEBORN-247][FOLLOWUP] Add metrics for each user's quota usage (#1206)

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

angerszhuuuu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new 46240d59d [CELEBORN-247][FOLLOWUP] Add metrics for each user's quota usage (#1206)
46240d59d is described below

commit 46240d59de1626f3ad429c734e45cc53b002d4c0
Author: Angerszhuuuu <an...@gmail.com>
AuthorDate: Mon Feb 6 14:02:57 2023 +0800

    [CELEBORN-247][FOLLOWUP] Add metrics for each user's quota usage (#1206)
---
 .../main/scala/org/apache/celeborn/service/deploy/master/Master.scala    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala b/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala
index b2c1c5994..ede301054 100644
--- a/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala
+++ b/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala
@@ -145,6 +145,7 @@ private[celeborn] class Master(
   masterSource.addGauge(MasterSource.IsActiveMaster, _ => isMasterActive)
 
   metricsSystem.registerSource(rpcSource)
+  metricsSystem.registerSource(resourceConsumptionSource)
   metricsSystem.registerSource(masterSource)
   metricsSystem.registerSource(new JVMSource(conf, MetricsSystem.ROLE_MASTER))
   metricsSystem.registerSource(new JVMCPUSource(conf, MetricsSystem.ROLE_MASTER))