diff --git a/server/src/main/java/org/opensearch/index/engine/SegmentsStats.java b/server/src/main/java/org/opensearch/index/engine/SegmentsStats.java index 0ff64bb43ad5c..f4fd2490c7abe 100644 --- a/server/src/main/java/org/opensearch/index/engine/SegmentsStats.java +++ b/server/src/main/java/org/opensearch/index/engine/SegmentsStats.java @@ -122,12 +122,9 @@ public SegmentsStats(StreamInput in) throws IOException { fileSizes = in.readMap(StreamInput::readString, StreamInput::readLong); if (in.getVersion().onOrAfter(Version.V_2_10_0)) { remoteSegmentStats = in.readOptionalWriteable(RemoteSegmentStats::new); - } else { - remoteSegmentStats = new RemoteSegmentStats(); - } - if (in.getVersion().onOrAfter(Version.V_3_0_0)) { replicationStats = in.readOptionalWriteable(ReplicationStats::new); } else { + remoteSegmentStats = new RemoteSegmentStats(); replicationStats = new ReplicationStats(); } } @@ -329,8 +326,6 @@ public void writeTo(StreamOutput out) throws IOException { out.writeMap(this.fileSizes, StreamOutput::writeString, StreamOutput::writeLong); if (out.getVersion().onOrAfter(Version.V_2_10_0)) { out.writeOptionalWriteable(remoteSegmentStats); - } - if (out.getVersion().onOrAfter(Version.V_3_0_0)) { out.writeOptionalWriteable(replicationStats); } }