From 199543d94f8fc06b61c81d6aac81d402099fa093 Mon Sep 17 00:00:00 2001 From: Suraj Singh Date: Tue, 10 Jan 2023 14:19:43 -0800 Subject: [PATCH] Send replicated boolean on supported versions Signed-off-by: Suraj Singh --- .../java/org/opensearch/index/seqno/ReplicationTracker.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/opensearch/index/seqno/ReplicationTracker.java b/server/src/main/java/org/opensearch/index/seqno/ReplicationTracker.java index e00fafaa10f13..13ff1b91727eb 100644 --- a/server/src/main/java/org/opensearch/index/seqno/ReplicationTracker.java +++ b/server/src/main/java/org/opensearch/index/seqno/ReplicationTracker.java @@ -712,7 +712,7 @@ public CheckpointState(StreamInput in) throws IOException { this.globalCheckpoint = in.readZLong(); this.inSync = in.readBoolean(); this.tracked = in.readBoolean(); - if (in.getVersion().onOrAfter(Version.CURRENT)) { + if (in.getVersion().onOrAfter(Version.V_2_5_0)) { this.replicated = in.readBoolean(); } else { this.replicated = true; @@ -725,7 +725,9 @@ public void writeTo(StreamOutput out) throws IOException { out.writeZLong(globalCheckpoint); out.writeBoolean(inSync); out.writeBoolean(tracked); - out.writeBoolean(replicated); + if (out.getVersion().onOrAfter(Version.V_2_5_0)) { + out.writeBoolean(replicated); + } } /**