This is an automated email from the ASF dual-hosted git repository.
zuston pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git
The following commit(s) were added to refs/heads/master by this push:
new 6f6d35aab [#378][FOLLOWUP] fix(server): Fix huge_partition_num metric
(#1669)
6f6d35aab is described below
commit 6f6d35aab8e9fe7002de3768e6d5a30cad2d4cb7
Author: RickyMa <[email protected]>
AuthorDate: Fri Apr 26 14:10:02 2024 +0800
[#378][FOLLOWUP] fix(server): Fix huge_partition_num metric (#1669)
### What changes were proposed in this pull request?
Fix the metric huge_partition_num.
### Why are the changes needed?
A follow-up PR for: https://github.com/apache/incubator-uniffle/pull/494.
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Existing UTs.
---
server/src/main/java/org/apache/uniffle/server/ShuffleTaskManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/server/src/main/java/org/apache/uniffle/server/ShuffleTaskManager.java
b/server/src/main/java/org/apache/uniffle/server/ShuffleTaskManager.java
index 95b70031f..11d654572 100644
--- a/server/src/main/java/org/apache/uniffle/server/ShuffleTaskManager.java
+++ b/server/src/main/java/org/apache/uniffle/server/ShuffleTaskManager.java
@@ -774,7 +774,7 @@ public class ShuffleTaskManager {
storageManager.removeResources(new AppPurgeEvent(appId,
shuffleTaskInfo.getUser()));
if (shuffleTaskInfo.hasHugePartition()) {
ShuffleServerMetrics.gaugeAppWithHugePartitionNum.dec();
-
ShuffleServerMetrics.gaugeHugePartitionNum.dec(shuffleTaskInfo.getHugePartitionSize());
+ ShuffleServerMetrics.gaugeHugePartitionNum.dec();
}
LOG.info(
"Finish remove resource for appId["