Skip to content

Commit

Permalink
Changed version
Browse files Browse the repository at this point in the history
  • Loading branch information
sahil buddharaju committed Jun 30, 2023
1 parent 3a690a4 commit 9ad4129
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,7 @@ private Stats(StreamInput in) throws IOException {
pitCurrent = in.readVLong();
}

if (in.getVersion().onOrAfter(Version.V_2_0_0)) {
if (in.getVersion().onOrAfter(Version.V_3_0_0)) {
this.coordinatorStatsLongHolder = new CoordinatorStatsLongHolder();
coordinatorStatsLongHolder.dfsPreQueryMetric = in.readVLong();
coordinatorStatsLongHolder.dfsPreQueryCurrent= in.readVLong();
Expand Down Expand Up @@ -353,7 +353,7 @@ public void writeTo(StreamOutput out) throws IOException {
out.writeVLong(pitCurrent);
}

if (out.getVersion().onOrAfter(Version.V_2_0_0)) {
if (out.getVersion().onOrAfter(Version.V_3_0_0)) {
out.writeVLong(coordinatorStatsLongHolder.dfsPreQueryMetric);
out.writeVLong(coordinatorStatsLongHolder.dfsPreQueryCurrent);
out.writeVLong(coordinatorStatsLongHolder.dfsPreQueryTotal);
Expand Down

0 comments on commit 9ad4129

Please sign in to comment.