Skip to content

Commit 0b9b66e

Browse files
committed
HDDS-15552. Ratis events should not be published as metrics
Change-Id: I06634562bad09e1cf308b3d2f9ec93d4b6c078fe
1 parent cb29f19 commit 0b9b66e

9 files changed

Lines changed: 21 additions & 6 deletions

File tree

hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/placement/metrics/SCMMetrics.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -180,7 +180,6 @@ public void addRatisEvent(String event) {
180180
}
181181
}
182182

183-
@Metric("Ratis state machine events")
184183
public String getRatisEvents() {
185184
synchronized (ratisEvents) {
186185
return String.join("\n", ratisEvents);

hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/SCMMXBean.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,4 +82,6 @@ public interface SCMMXBean extends ServiceRuntimeInfo {
8282
* @return the SCM hostname for the datanode.
8383
*/
8484
String getHostname();
85+
86+
String getRatisEvents();
8587
}

hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2238,6 +2238,11 @@ public String getHostname() {
22382238
return scmHostName;
22392239
}
22402240

2241+
@Override
2242+
public String getRatisEvents() {
2243+
return metrics != null ? metrics.getRatisEvents() : "";
2244+
}
2245+
22412246
public Collection<String> getScmAdminUsernames() {
22422247
return scmAdmins.getAdminUsernames();
22432248
}

hadoop-hdds/server-scm/src/main/resources/webapps/scm/scm.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,10 +30,10 @@
3030
templateUrl: 'ratis-events.html',
3131
controller: function ($http) {
3232
var ctrl = this;
33-
$http.get("jmx?qry=Hadoop:service=StorageContainerManager,name=SCMMetrics")
33+
$http.get("jmx?qry=Hadoop:service=StorageContainerManager,name=StorageContainerManagerInfo,component=ServerRuntime")
3434
.then(function (result) {
3535
var metrics = result.data.beans[0];
36-
var rawEvents = metrics['tag.RatisEvents'] ? metrics['tag.RatisEvents'].split('\n') : [];
36+
var rawEvents = (metrics && metrics['RatisEvents']) ? metrics['RatisEvents'].split('\n') : [];
3737
ctrl.events = rawEvents.map(function(e) {
3838
var parts = e.split('|');
3939
return {

hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/hdds/scm/TestSCMMXBean.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,9 @@ public void testSCMMXBean() throws Exception {
8686
double containerThreshold = (double) mbs.getAttribute(bean,
8787
"SafeModeCurrentContainerThreshold");
8888
assertEquals(scm.getCurrentContainerThreshold(), containerThreshold, 0);
89+
90+
String ratisEvents = (String) mbs.getAttribute(bean, "RatisEvents");
91+
assertEquals(scm.getMetrics().getRatisEvents(), ratisEvents);
8992
}
9093

9194
@Test

hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMMXBean.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,4 +41,6 @@ public interface OMMXBean extends ServiceRuntimeInfo {
4141
* @return the OM hostname for the datanode.
4242
*/
4343
String getHostname();
44+
45+
String getRatisEvents();
4446
}

hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMMetrics.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1590,7 +1590,6 @@ public void addRatisEvent(String event) {
15901590
}
15911591
}
15921592

1593-
@Metric("Ratis state machine events")
15941593
public String getRatisEvents() {
15951594
synchronized (ratisEvents) {
15961595
return String.join("\n", ratisEvents);

hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3307,6 +3307,11 @@ public String getHostname() {
33073307
return omHostName;
33083308
}
33093309

3310+
@Override
3311+
public String getRatisEvents() {
3312+
return metrics != null ? metrics.getRatisEvents() : "";
3313+
}
3314+
33103315
@VisibleForTesting
33113316
public OzoneManagerHttpServer getHttpServer() {
33123317
return httpServer;

hadoop-ozone/ozone-manager/src/main/resources/webapps/ozoneManager/ozoneManager.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -173,10 +173,10 @@
173173
templateUrl: 'ratis-events.html',
174174
controller: function ($http) {
175175
var ctrl = this;
176-
$http.get("jmx?qry=Hadoop:service=OzoneManager,name=OMMetrics")
176+
$http.get("jmx?qry=Hadoop:service=OzoneManager,name=OzoneManagerInfo,component=ServerRuntime")
177177
.then(function (result) {
178178
var metrics = result.data.beans[0];
179-
var rawEvents = metrics['tag.RatisEvents'] ? metrics['tag.RatisEvents'].split('\n') : [];
179+
var rawEvents = (metrics && metrics['RatisEvents']) ? metrics['RatisEvents'].split('\n') : [];
180180
ctrl.events = rawEvents.map(function(e) {
181181
var parts = e.split('|');
182182
return {

0 commit comments

Comments
 (0)