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))