Skip to content

Commit

Permalink
[Search latency - Coordinator] Changing version check to 2.11
Browse files Browse the repository at this point in the history
Signed-off-by: Sagar Upadhyaya <sagar.upadhyaya.121@gmail.com>
  • Loading branch information
sgup432 committed Sep 29, 2023
1 parent 7dc6683 commit b29a6fd
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -242,7 +242,7 @@ private Stats(StreamInput in) throws IOException {
pitCurrent = in.readVLong();
}

if (in.getVersion().onOrAfter(Version.V_3_0_0)) {
if (in.getVersion().onOrAfter(Version.V_2_11_0)) {
this.requestStatsLongHolder = new RequestStatsLongHolder();
requestStatsLongHolder.requestStatsHolder = in.readMap(StreamInput::readString, PhaseStatsLongHolder::new);
}
Expand Down Expand Up @@ -437,7 +437,7 @@ public void writeTo(StreamOutput out) throws IOException {
out.writeVLong(pitCurrent);
}

if (out.getVersion().onOrAfter(Version.V_3_0_0)) {
if (out.getVersion().onOrAfter(Version.V_2_11_0)) {
if (requestStatsLongHolder == null) {
requestStatsLongHolder = new RequestStatsLongHolder();
}
Expand Down

0 comments on commit b29a6fd

Please sign in to comment.