do not remove

apache · Nov 26, 2024 · 25d57b3 · 25d57b3
1 parent a08e68c
commit 25d57b3
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala
@@ -677,8 +677,6 @@ private[celeborn] class Worker(
   private def handleTopResourceConsumption(userResourceConsumptions: util.Map[
     UserIdentifier,
     ResourceConsumption]): Unit = {
-    // Remove application top resource consumption gauges to refresh top resource consumption metrics.
-    removeAppResourceConsumption(topApplicationUserIdentifiers.keySet().asScala)
     // Top resource consumption is determined by diskBytesWritten+hdfsBytesWritten.
     userResourceConsumptions.asScala.filter(userResourceConsumption =>
       CollectionUtils.isNotEmpty(userResourceConsumption._2.subResourceConsumptions))