This is an automated email from the ASF dual-hosted git repository.
ritesh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 8ee276c1d4 HDDS-9271. SortDatanodes metric in OM getKeyInfo (#5280)
8ee276c1d4 is described below
commit 8ee276c1d4701cb800cdf5aeab7d48963868519c
Author: Duong Nguyen <[email protected]>
AuthorDate: Tue Sep 12 13:51:07 2023 -0700
HDDS-9271. SortDatanodes metric in OM getKeyInfo (#5280)
---
.../src/main/java/org/apache/hadoop/ozone/om/KeyManagerImpl.java | 3 ++-
.../main/java/org/apache/hadoop/ozone/om/OMPerformanceMetrics.java | 7 +++++++
2 files changed, 9 insertions(+), 1 deletion(-)
diff --git
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/KeyManagerImpl.java
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/KeyManagerImpl.java
index 10d60033fa..505096c9eb 100644
---
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/KeyManagerImpl.java
+++
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/KeyManagerImpl.java
@@ -1955,7 +1955,8 @@ public class KeyManagerImpl implements KeyManager {
args.isForceUpdateContainerCacheFromSCM()));
if (args.getSortDatanodes()) {
- sortDatanodes(clientAddress, value);
+ captureLatencyNs(metrics.getGetKeyInfoSortDatanodesLatencyNs(),
+ () -> sortDatanodes(clientAddress, value));
}
}
return value;
diff --git
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMPerformanceMetrics.java
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMPerformanceMetrics.java
index d18000e167..5b0829a088 100644
---
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMPerformanceMetrics.java
+++
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMPerformanceMetrics.java
@@ -74,6 +74,9 @@ public class OMPerformanceMetrics {
@Metric(about = "ACLs check in getKeyInfo")
private MutableRate getKeyInfoAclCheckLatencyNs;
+ @Metric(about = "Sort datanodes latency in getKeyInfo")
+ private MutableRate getKeyInfoSortDatanodesLatencyNs;
+
@Metric(about = "resolveBucketLink latency in getKeyInfo")
private MutableRate getKeyInfoResolveBucketLatencyNs;
@@ -142,6 +145,10 @@ public class OMPerformanceMetrics {
return getKeyInfoResolveBucketLatencyNs;
}
+ public MutableRate getGetKeyInfoSortDatanodesLatencyNs() {
+ return getKeyInfoSortDatanodesLatencyNs;
+ }
+
public void setForceContainerCacheRefresh(boolean value) {
forceContainerCacheRefresh.add(value ? 1L : 0L);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
