Remove unnecessary input.setVersion line

Co-authored-by: Andrew Ross <[email protected]> Signed-off-by: Aman Khare <[email protected]>
opensearch-project · Jun 6, 2023 · 5605928 · 5605928
1 parent ad2bdcc
commit 5605928
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/cluster/coordination/JoinHelper.java b/server/src/main/java/org/opensearch/cluster/coordination/JoinHelper.java
@@ -261,7 +261,6 @@ private void handleCompressedValidateJoinRequest(
         BytesTransportRequest request
     ) throws IOException {
         try (StreamInput input = CompressedStreamUtils.decompressBytes(request, namedWriteableRegistry)) {
-            input.setVersion(request.version());
             ClusterState incomingState = ClusterState.readFrom(input, transportService.getLocalNode());
             runJoinValidators(currentStateSupplier, incomingState, joinValidators);
         }