Skip to content

Commit 71d122b

Browse files
correcting shard routing version (#15554)
Signed-off-by: Bharathwaj G <[email protected]>
1 parent 03d9a24 commit 71d122b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/src/main/java/org/opensearch/cluster/routing/ShardRouting.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -358,7 +358,7 @@ public ShardRouting(ShardId shardId, StreamInput in) throws IOException {
358358
currentNodeId = in.readOptionalString();
359359
relocatingNodeId = in.readOptionalString();
360360
primary = in.readBoolean();
361-
if (in.getVersion().onOrAfter(Version.V_3_0_0)) {
361+
if (in.getVersion().onOrAfter(Version.V_2_17_0)) {
362362
searchOnly = in.readBoolean();
363363
} else {
364364
searchOnly = false;
@@ -396,7 +396,7 @@ public void writeToThin(StreamOutput out) throws IOException {
396396
out.writeOptionalString(currentNodeId);
397397
out.writeOptionalString(relocatingNodeId);
398398
out.writeBoolean(primary);
399-
if (out.getVersion().onOrAfter(Version.V_3_0_0)) {
399+
if (out.getVersion().onOrAfter(Version.V_2_17_0)) {
400400
out.writeBoolean(searchOnly);
401401
}
402402
out.writeByte(state.value());

0 commit comments

Comments
 (0)