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

xuba pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git


The following commit(s) were added to refs/heads/master by this push:
     new b61383b2a [Hotfix] Fetch the latest MemoryUsage inside each gauge call 
(#4062)
b61383b2a is described below

commit b61383b2a03dcf9dd447ed2cceea4bdd143bda2e
Author: 7hong <[email protected]>
AuthorDate: Thu Jan 29 10:36:56 2026 +0800

    [Hotfix] Fetch the latest MemoryUsage inside each gauge call (#4062)
    
    [Hotfix] Fetch the latest MemoryUsage inside each gauge call.
    
    fix checkstyle
---
 .../java/org/apache/amoro/server/AmsServiceMetrics.java   | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)

diff --git 
a/amoro-ams/src/main/java/org/apache/amoro/server/AmsServiceMetrics.java 
b/amoro-ams/src/main/java/org/apache/amoro/server/AmsServiceMetrics.java
index 64e2c591c..973594c91 100644
--- a/amoro-ams/src/main/java/org/apache/amoro/server/AmsServiceMetrics.java
+++ b/amoro-ams/src/main/java/org/apache/amoro/server/AmsServiceMetrics.java
@@ -30,7 +30,7 @@ import 
org.apache.amoro.shade.guava32.com.google.common.collect.Lists;
 
 import java.lang.management.GarbageCollectorMXBean;
 import java.lang.management.ManagementFactory;
-import java.lang.management.MemoryUsage;
+import java.lang.management.MemoryMXBean;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
@@ -108,16 +108,21 @@ public class AmsServiceMetrics {
   }
 
   private void registerHeapMetric() {
-    MemoryUsage heapMemoryUsage = 
ManagementFactory.getMemoryMXBean().getHeapMemoryUsage();
+    MemoryMXBean memoryMXBean = ManagementFactory.getMemoryMXBean();
     registerMetric(
-        registry, AMS_JVM_MEMORY_HEAP_USED, (Gauge<Long>) () -> 
heapMemoryUsage.getUsed());
+        registry,
+        AMS_JVM_MEMORY_HEAP_USED,
+        (Gauge<Long>) () -> memoryMXBean.getHeapMemoryUsage().getUsed());
 
     registerMetric(
         registry,
         AMS_JVM_MEMORY_HEAP_COMMITTED,
-        (Gauge<Long>) () -> heapMemoryUsage.getCommitted());
+        (Gauge<Long>) () -> memoryMXBean.getHeapMemoryUsage().getCommitted());
 
-    registerMetric(registry, AMS_JVM_MEMORY_HEAP_MAX, (Gauge<Long>) () -> 
heapMemoryUsage.getMax());
+    registerMetric(
+        registry,
+        AMS_JVM_MEMORY_HEAP_MAX,
+        (Gauge<Long>) () -> memoryMXBean.getHeapMemoryUsage().getMax());
   }
 
   private void registerThreadMetric() {

Reply via email to