From 046e26cee4312fd5018b3a4d968fb8acc5afc6c1 Mon Sep 17 00:00:00 2001 From: Vinay Krishna Pudyodu Date: Tue, 10 Dec 2024 21:22:32 -0800 Subject: [PATCH] Fixed failing integ tests Signed-off-by: Vinay Krishna Pudyodu --- .../indices/replication/SegmentReplicationStatsIT.java | 1 + .../replication/TransportSegmentReplicationStatsAction.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/server/src/internalClusterTest/java/org/opensearch/indices/replication/SegmentReplicationStatsIT.java b/server/src/internalClusterTest/java/org/opensearch/indices/replication/SegmentReplicationStatsIT.java index b2161577f7040..89aef6f0be1a6 100644 --- a/server/src/internalClusterTest/java/org/opensearch/indices/replication/SegmentReplicationStatsIT.java +++ b/server/src/internalClusterTest/java/org/opensearch/indices/replication/SegmentReplicationStatsIT.java @@ -432,4 +432,5 @@ public void testSegmentReplicationNodeAndIndexStats() throws Exception { } } + } diff --git a/server/src/main/java/org/opensearch/action/admin/indices/replication/TransportSegmentReplicationStatsAction.java b/server/src/main/java/org/opensearch/action/admin/indices/replication/TransportSegmentReplicationStatsAction.java index 1a4f073941494..44408c5043fcf 100644 --- a/server/src/main/java/org/opensearch/action/admin/indices/replication/TransportSegmentReplicationStatsAction.java +++ b/server/src/main/java/org/opensearch/action/admin/indices/replication/TransportSegmentReplicationStatsAction.java @@ -201,7 +201,7 @@ private SegmentReplicationPerGroupStats updateGroupStats( Set combinedStats = Stream.concat(updatedReplicaStats.stream(), searchReplicaStats.stream()) .collect(Collectors.toSet()); - return new SegmentReplicationPerGroupStats(groupStats.getShardId(), combinedStats, 0); + return new SegmentReplicationPerGroupStats(groupStats.getShardId(), combinedStats, groupStats.getRejectedRequestCount()); } private Set computeSearchReplicaStats(