Skip to content

Commit 376d1d6

Browse files
committed
Improve MRT handling
1 parent d9f7320 commit 376d1d6

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

server/src/main/java/org/elasticsearch/action/admin/cluster/stats/CCSUsageTelemetry.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,11 @@ private void doUpdate(CCSUsage ccsUsage) {
159159
skippedRemotes.increment();
160160
ccsUsage.getSkippedRemotes().forEach(remote -> byRemoteCluster.computeIfAbsent(remote, PerClusterCCSTelemetry::new).skipped());
161161
}
162-
ccsUsage.getFeatures().forEach(f -> featureCounts.computeIfAbsent(f, k -> new LongAdder()).increment());
162+
ccsUsage.getFeatures().forEach(f -> {
163+
if (useMRT || f.equals(MRT_FEATURE) == false) {
164+
featureCounts.computeIfAbsent(f, k -> new LongAdder()).increment();
165+
}
166+
});
163167
String client = ccsUsage.getClient();
164168
if (client != null && KNOWN_CLIENTS.contains(client)) {
165169
// We count only known clients for now

server/src/test/java/org/elasticsearch/action/admin/cluster/stats/CCSUsageTelemetryTests.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -358,5 +358,6 @@ public void testUseMRTFalse() {
358358
assertThat(snapshot.getTook().count(), equalTo(2L));
359359
assertThat(snapshot.getTookMrtFalse().count(), equalTo(0L));
360360
assertThat(snapshot.getTookMrtTrue().count(), equalTo(0L));
361+
assertThat(snapshot.getFeatureCounts().size(), equalTo(0));
361362
}
362363
}

0 commit comments

Comments
 (0)