Browse Source

Adjust serialization version after backport

Zachary Tong 6 years ago
parent
commit
363a7eb59a

+ 2 - 2
server/src/main/java/org/elasticsearch/search/aggregations/pipeline/MovFnPipelineAggregationBuilder.java

@@ -101,7 +101,7 @@ public class MovFnPipelineAggregationBuilder extends AbstractPipelineAggregation
         format = in.readOptionalString();
         gapPolicy = GapPolicy.readFrom(in);
         window = in.readInt();
-        if (in.getVersion().onOrAfter(Version.V_8_0_0)) { // TODO change this after backport
+        if (in.getVersion().onOrAfter(Version.V_7_4_0)) {
             shift = in.readInt();
         } else {
             shift = 0;
@@ -115,7 +115,7 @@ public class MovFnPipelineAggregationBuilder extends AbstractPipelineAggregation
         out.writeOptionalString(format);
         gapPolicy.writeTo(out);
         out.writeInt(window);
-        if (out.getVersion().onOrAfter(Version.V_8_0_0)) { // TODO change this after backport
+        if (out.getVersion().onOrAfter(Version.V_7_4_0)) {
             out.writeInt(shift);
         }
     }

+ 2 - 2
server/src/main/java/org/elasticsearch/search/aggregations/pipeline/MovFnPipelineAggregator.java

@@ -83,7 +83,7 @@ public class MovFnPipelineAggregator extends PipelineAggregator {
         gapPolicy = BucketHelpers.GapPolicy.readFrom(in);
         bucketsPath = in.readString();
         window = in.readInt();
-        if (in.getVersion().onOrAfter(Version.V_8_0_0)) { // TODO change this after backport
+        if (in.getVersion().onOrAfter(Version.V_7_4_0)) {
             shift = in.readInt();
         } else {
             shift = 0;
@@ -97,7 +97,7 @@ public class MovFnPipelineAggregator extends PipelineAggregator {
         gapPolicy.writeTo(out);
         out.writeString(bucketsPath);
         out.writeInt(window);
-        if (out.getVersion().onOrAfter(Version.V_8_0_0)) { // TODO change this after backport
+        if (out.getVersion().onOrAfter(Version.V_7_4_0)) {
             out.writeInt(shift);
         }
     }