Skip to content

Commit 1207980

Browse files
kevin.cyjwsry
authored andcommitted
[hotfix] Fix cluster max used storage space metrics
1 parent 5b11fe8 commit 1207980

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

shuffle-coordinator/src/main/java/com/alibaba/flink/shuffle/coordinator/manager/assignmenttracker/AssignmentTrackerImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -111,8 +111,8 @@ private void registerMetrics() {
111111
ClusterMetricsUtil.registerNumShuffleWorkers(workers::size);
112112
ClusterMetricsUtil.registerHddMaxFreeBytes(this::getHddMaxStorageFreeSpace);
113113
ClusterMetricsUtil.registerSsdMaxFreeBytes(this::getSsdMaxStorageFreeSpace);
114-
ClusterMetricsUtil.registerHddMaxUsedBytes(this::getHddMaxStorageFreeSpace);
115-
ClusterMetricsUtil.registerSsdMaxUsedBytes(this::getSsdMaxStorageFreeSpace);
114+
ClusterMetricsUtil.registerHddMaxUsedBytes(this::getHddMaxStorageUsedSpace);
115+
ClusterMetricsUtil.registerSsdMaxUsedBytes(this::getSsdMaxStorageUsedSpace);
116116
}
117117

118118
public long getHddMaxStorageFreeSpace() {

0 commit comments

Comments
 (0)